济南做网站最好的公司重庆百度推广开户

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