MyKafkaMS 一个基于kafka中间件的高并发情况下顺序执行消息的消息系统 系统服务器采用kafka官网提供的java脚本来创建,参数kafka / config / server.propertities如下: 经纪人的ID。 对于每个代理,必须将其设置为唯一的整数。 broker.id = 0 服务器用于接收来自网络的请求并向网络发送响应的线程数 num.network.threads = 3 服务器用于处理请求的线程数,其中可能包括磁盘I / O num.io.threads = 8 套接字服务器使用的发送缓冲区(SO_SNDBUF) socket.send.buffer.b