-
这是一个在高并发场景下仍能确保消息顺序执行的、基于Kafka消息中间件的消息系统,命名为MyKafkaMs
资源介绍
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.bytes = 102400
套接字服务器使用的接收缓冲区(SO_RCVBUF)
socket.receive.buffer.bytes = 102400
套接字服务器将接受的请求的最大大小(针对OO
- 上一篇: winhex-forensics 15.5
- 下一篇: SpringBoot+文件上传