1.持久化需要重新设置队列
2.异步发布确认的坑, 生产者发消息太快只会确认最大的编号
1.消费者还是要确认消息
channel.basicAck(message.getEnvelope().getDeliveryTag(), false); 因为你发送的太快了，只会返回成功接收的最大的编号
3.消费者消息堆积(开启了消息手动确认,但是没有确认)
1.消费者要应答
DeliverCallback deliverCallback=(tag, delivery)->{
channel.basicAck(delivery.getEnvelope().getDeliveryTag(),false);
System.out.println("consumer1"+new String(delivery.getBody(),"UTF-8"));
};
2.消息提供者开启应答
channel.confirmSelect();
4.调用的方法不提示参数名,下载源代码即可
5.@Qualifier(“名字”)报错,导包错误
import org.mapstruct.Qualifier; //改为spring的
import org.springframework.beans.factory.annotation.Qualifier;
6.每改一个队列和交换机参数要删除队列和交换机,不然报 /host xxxx错误
7.交换机和队列声明多用 builder可以带很多参数
8.原生java连接mq的坑 ,最好设置两边提供者和消费者的参数(不论是优先队列还是惰性队列还是其他)
9.改参数一直有报错,同时删除队列和交换机
10.设置惰性队列,优先队列也可以使用(解决了)
11.创建交换机队列,绑定一定要用builder
12.坑了3天
联邦交换机 policy必须要删除其他之前同步的策略才能使用
13.联邦上游的坑
1.生产者发送消息,消费者会接收2次消息,原因是我把上游设置为他节点本身,所以
导致给上游备份的数据,又给本身节点,所以有两份数据
2.如果上游搞好了,那么下游消费数据,上游数据是也会更新状态
3.下游节点宕机,上游需要一个时间切换 需要负载均衡
4.下游恢复正常数据还是存在,还是需要设置一个id区分消息是否消费(不然重复消费)
14.学习完全部,建立了MQ集群发现出现 node3 is no accessible的异常,需要改界面的node名称为对应主机设置的名称
就是cluster那一行 如图mq集群节点异常
