当前位置: 首页 > 网络应用技术

RocketMQ介绍和实践

时间:2023-03-09 10:18:07 网络应用技术

  主流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