RocketMQ
未读
RocketMq死信队列
介绍 如果消息重试次数超过了最大的重试次数，那么RocketMQ就会把这个消息丢到死信队列中。RocketMQ默认的重试次数是16次。见源码 org.apache.rocketmq.common.subscription.SubscriptionGroupConfig中的retryMaxTimes属
RocketMQ
未读
RocketMq事务消息示例
说到RocketMq的事务消息，那么涉及到的一定是分布式的事务，本地的事务也用不到这些中间件。但是说到分布式事务，了解的人一般会想到2PC、3PC、TCC、Seata这些，但是这些分布式事务都是强一致性的事务。其实还有一种解决方案叫做最终一致性也称为消息事务。而RabbitMq事务消息就是消息事务的
RocketMQ
未读
RocketMq定时/延时消息示例
什么是定时消息 定时消息是 Apache RocketMQ 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。 定时时间设置原则 Apache RocketMQ 定时消息设置的定时时间是一个预期触发的系统时间戳，延
RocketMQ
未读
RocketMq顺序消息示例
顺序消息最主要的是让生产的消息进入同一个队列中 rocketmq-client版本 在这个sdk版本中是要指定一个消息队列，这样消息才能按顺序进入主题下的同一个队列 至于顺序消息的概念建议还是看官方文档，文档地址：https://rocketmq.apache.org/zh/docs/feature
RocketMQ
未读
Rocketmq-client 中 MessageListenerOrderly和MessageListenerConcurrently的区别
在消费者设置并发线程和单次最大拉取消息数量为1时，当消息拉取失败MessageListenerOrderly 会一直重试当前消息阻塞后面消息的消费。而MessageListenerConcurrently则会把消息挂起先消费后面的消息，在达到消息重试间隔时间后重新消费失败的消息。 例如下面的代码和控
RocketMQ
未读
RocketMQ普通消息示例
创建生产者并发送消息 普通java项目 首先我们创建一个工具类来获取与服务端通信的相关配置 public class RocketMqUtil {
// 设置成nameser的地址端口。
private static String ENDPOINT = "192.168.
RocketMQ
未读
RocketMq创建主题
通过命令行创建 使用docker命令部署的进入容器内，进入命令如下 docker exec -it [容器id或容器名称] /bin/bash 无论是否在容器内进入到 rocketmq5.3.0/bin 目录下,执行如下命令 ./mqadmin updatetopic -n localhost:98
RocketMQ
未读
Rancher搭建单节点Rocketmq
前言 网上和官网上有很多关于怎么使用单机、docker、docker-compose搭建环境的教程，但是我本地的虚拟机搭建的有一套基于rke2+rancher的环境。所以不太想使用docker部署而是想把服务直接部署到rancher中。但是期间踩了好几个坑，所以记录一下防止以后忘记，也希望能够帮助到
中间件
未读
RedisTemplate最全的常用方法总结
RedisTemplate最全的常用方法总结 Redis常用的数据类型： String Hash List Set zSet Sorted set String类型 判断是否有key所对应的值，有则返回true，没有则返回false redisTemplate.hasKey(key)
有则取出ke
中间件
未读
RabbitMQ学习笔记
RabbitMQ学习笔记 MQ的相关概念 什么是MQ MQ(message queue)，从字面意思上看，本质是个队列， FIFO 先入先出，只不过队列中存放的内容是message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中， MQ 是一种非常常见的上下游“逻辑解耦+物理解耦