xxl-mq
2016-12-05 15:24:54 0 举报
XXL-MQ是一个轻量级分布式消息队列,它支持高可用、高性能和可扩展的消息传递。它采用了基于内存的存储模式,因此具有快速响应和低延迟的特点。XXL-MQ提供了丰富的功能,包括消息持久化、消息过滤、消息追踪等。它还支持多种消息协议,如AMQP、STOMP、HTTP等,可以与各种消息中间件无缝集成。此外,XXL-MQ还提供了易于使用的Java API,使得开发人员可以轻松地在其应用程序中使用消息队列。总之,XXL-MQ是一个强大而灵活的分布式消息队列解决方案,适用于各种规模的企业应用。
作者其他创作
大纲/内容
启动consumer线程
initQueueConsumer
添加到XxlMqBroker queue中
第一次实例化zk要执行绑定discoverConsumers之后60s执行一次
zk绑定Watcher节点更变执行discoverConsumers()
consumerAddress 维护consumer地址regKey-addresSet一个regKey对应多个address
XxlMqConsumer.setApplicationContext 初始化寻找所有consumer(包装成QueueConsumerThread)放入ConsumerRespository
线程每个60s重新注册
/xxl-rpc/registry-key/address节点 注册到 zk
ZkQueueConsumerUtil.registerConsumers每隔60s重新注册
0 条评论
下一页