主流MQ比较:Kafka,RocketMQ,RabbitMQ Kafka:Apache下的子-Projects,使用Scala实现的高性性分布式发布/订阅消息Queue System(对于日志字段)。
RocketMQ:前任是元解。发布后,它重命名为RocketMQ.RocketMQ是分布式的,队列模型消息中间件(正常业务)
RABBITMQ:Erlang编写的开源消息队列本身支持许多协议:AMQP,XMPP,SMTP,Stomp,这使其非常重量级,适合企业 - 级别的开发
在发送/接收消息之前发送和读取消息,我们需要告诉客户端名称server.RocketMQ提供了多种实现此功能的方法。简单性,我们使用环境变量namesrv_addr
注意:如果我们的计算机磁盘不足(超过使用空间的90%以上),我们无法发送消息,我们可以通过将阈值添加到启动参数(文件位置)来解决它
下载地址:https://github.com/apache/rockemq-externals/选择标签并下载
开始命令:
启动日志:启动后运行的效果如下:
RocketMQ使用FIFO订单提供有序的新闻。以下示例演示了全局和分区排序消息的发送/接收。
消息生产者:
消息订阅者:
广播是给主题所有订阅者的信息。如果您希望所有订阅者都会收到有关主题的新闻,那么广播是一个不错的选择。
消息生产者:
消息订户
延迟消息级别的取代者:
消息发布者:消息设置的delayTimelevel对应
批处理新闻,每次限制1MB
消息订阅者:
新闻发布者
原始:https://juejin.cn/post/71031745937577246