登录 注册
当前位置:主页 > 资源下载 > 44 > 这是一个在高并发场景下仍能确保消息顺序执行的、基于Kafka消息中间件的消息系统,命名为MyKafkaMs

这是一个在高并发场景下仍能确保消息顺序执行的、基于Kafka消息中间件的消息系统,命名为MyKafkaMs

  • 更新:2024-12-10 09:20:50
  • 大小:54.89MB
  • 推荐:★★★★★
  • 来源:网友上传分享
  • 类别:其它 - 开发技术
  • 格式:ZIP

资源介绍

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