MQ的重试机制 由于MQ经常处于复杂的分布式系统中，考虑网络波动、服务宕机、程序异常因素，很有可能出现消息发送或者消费失败的问题。因此，消息的重试就是所有MQ中间件必须考虑到的一个关键点。如果没有消息重试，就可能产生消息丢失的问题，可能对系统产生很大的影响。所以，秉承宁可多发消息，也不可丢失消息的原
2023-04-02
事务消息是RocketMQ提供的非常重要的一个特性，在4.x版本之后开源，可以利用事务消息轻松地实现分布式事务。本文对RocketMQ的事务消息进行详细介绍，并给出了代码示例。 相关概念 RocketMQ在其消息定义的基础上，对事务消息扩展了两个相关的概念： Half(Prepare) Mess
2023-04-02
RocketMQ的消息模式 在RocketMQ中，可以理解为没有ActiveMQ的createQueue()和createTopic()的用法，也就是并没有P2P和Pub/Sub类似的概念。RocketMQ不遵循JMS规范，而是使用了一套自定义的机制。可以理解为RocketMQ都是基于Pub/Sub
2023-04-02
前言 最近项目中使用阿里的RocketMQ来做消息队列，具体怎么使用RocketMQ不在本文讨论范围之内，其相关帮助文档可以参考如下链接 https://help.aliyun.com/product/29530.html 本文主要记录在使用rocketmq client时，遇到的一些坑，作者
2023-03-26
RocketMQ延时消息 RocketMQ提供一种延时消息的解决方案，就是在特定的时间到了，消息才会被投递出去供consumer消费。 总体来说可以满足简单的场景是，但是需要注意的是延时的时间是需要按照内置的延时级别去配置的，而不是随意设置消息的延时时间。 如果想不受延时级别的约束，可以参考：ht
2023-03-24
Producer 介绍 消息发送的步骤 1) 设置 Producer 的 GroupName (Producer Group是一类 Producer 的集合) 2) 设置 InstanceName，当一个 JVM 需要启动多个 Producer 时，需要指定不同的 InstanceName 来区分
2023-03-24
开放端口 9876：NameServer端口 10909：VIP通道端口 10911：主Broker端口 10912：从Broker端口 10909是VIP通道对应的端口，在JAVA中的消费者对象或者是生产者对象中关闭VIP通道即可无需开放10909端口 使用如下方法 setVipChannelE
2023-03-24
Github：https://github.com/apache/rocketmq-externals.git 配置 进入rocketmq-externals\rocketmq-console\src\main\resources文件夹，打开application.properties进行配置 s
2023-03-24
可靠同步发送 同步发送是指消息发送方发出数据后，会在收到接收方发回响应之后才发下一个数据包的通讯方式。 调用DefaultMQProducer的send方法 public class SyncProducer { public static void main(String[] args)
2023-03-19
RocketMQ简介 官网：http://rocketmq.apache.org/docs/quick-start/ GitHub：https://github.com/apache/rocketmq/ RcoketMQ是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性： 支持发布
2023-03-09