动易网站 教程桂林人论坛桂林板路
1 rabbitmq设计
生产者并不是直接将消息投递到queue，而是发送给exchange，由exchange根据type的规则来选定投递的queue，这样消息设计在生产者和消费者就实现解耦。
rabbitmq会给没有type预定义一些exchage，而实际我们却应该使用自己定义的。
1.1 用户注册设计
用户在官网注册，因为官网与其他各子系统是分库的，因此涉及到用户注册后，用户的账号信息也需要同步各子产品，于是就有了下面的设计。2018的时候SOA设计我还用通过otter进行同步，但是现在觉得还不如使用rabbitmq，因为消息队列有很多作用，而且有些情况是，各个子系统承建时间不一样，各自的创建用户后，也会触发其他的操作，这些otter的小表复制策略就不是那么好了。
1.1.1 生产者
岁月云官网，可以看到这个里面只需要一个exchange名称即可，将对象转成字符串作为消息发送过去即可。
1.1.2 消费者
消费者中定义的监听是针对queue，ignoreDeclarationExceptions是幂等设计，可以确保即使某个实例的声明操作失败（例如，因为另一个实例已经成功声明了相同的资源），整个系统仍然可以正常工作。
fanout是一种广播，绑定到此eayc_user_add_change的queue都可以收到此消息。因为从官网下发的消息，到各子系统都应该收到，并各自创建。
下面是子系统acc的配置
具体消费的代码如下所示，
下面是子系统ps的配置，与acc使用同一个exchange，但queue是不同的。
1.2 死信队列和延时队列
x-message-ttl定义了消息的时间生存期，有了这特性，就可以拓展一些功能，比如高并发的流量控制。
下面通过x-message-ttl设置了一个延迟队列，通过DECLARE_DEAD_ROUTING_KEY与死信交换机declareDeadExchange进行匹配路由。
@Configuration
public class RabbitMQDelayConfig {@Value("${spring.rabbitmq.declare.exchange}")private String DECLARE_EXCHANGE;@Value("${spring.rabbitmq.declare.queue}")private String DECLARE_QUEUE;@Value("${spring.rabbitmq.decl