最近写了一个demo：demo的github地址一.简单介绍1.Server端它是一个WebApi服务，把它当成一个黑盒就行了。2.MiddleServer端是重点，它是一个WebApi服务，包含一个GetValues接口和一个Query2接口。Query2接口是一个简单的接口。GetValues接口通过请求Server端的GetCounts接口和GetValues接口获取数据。3.Client端请求500次MiddleServer端的GetValues接口和请求500次Query2接口。并行度200。二.这个demo主要测试什么？测试MiddleServer端两个接口的吞吐量，MiddleS

最近写了一个demo：demo的github地址一.简单介绍1.Server端它是一个WebApi服务，把它当成一个黑盒就行了。2.MiddleServer端是重点，它是一个WebApi服务，包含一个GetValues接口和一个Query2接口。Query2接口是一个简单的接口。GetValues接口通过请求Server端的GetCounts接口和GetValues接口获取数据。3.Client端请求500次MiddleServer端的GetValues接口和请求500次Query2接口。并行度200。二.这个demo主要测试什么？测试MiddleServer端两个接口的吞吐量，MiddleS

需求分析目的重构某个由定时任务调度的系统，升级为流式系统。技术选型kafka-stream2.7.0kafka2.7.0整体流程消费source-topic的order数据窗口聚合:windowBy,aggregate若干中间处理器:map、filter...，最终组成task扁平展开为多条数据:flatMap将task数据发往下游sink-topicstream-system.png程序实现(demo)kafka基础配置privatestaticPropertiesbuildConfigProps(){Propertiesprops=newProperties();Stringapplica

需求分析目的重构某个由定时任务调度的系统，升级为流式系统。技术选型kafka-stream2.7.0kafka2.7.0整体流程消费source-topic的order数据窗口聚合:windowBy,aggregate若干中间处理器:map、filter...，最终组成task扁平展开为多条数据:flatMap将task数据发往下游sink-topicstream-system.png程序实现(demo)kafka基础配置privatestaticPropertiesbuildConfigProps(){Propertiesprops=newProperties();Stringapplica