开始
还可以声明另外的绑定。order.deliveryman是order和骑手微服务做通信
exchange的参数
灰色是默认的,这里不写也可以。
第三个绑定
交换机类型是fanout ,所以必须声明出来了
第四个绑定
topic类型
我们通过注解,把rabbitConfig内的 这么多的代码用注解去实现了。声明的一堆绑定和交换机。
把之前声明的这一堆事注释掉。
把队列和交换机都先删掉。
这里交换机保留了商家的,因为商家微服务还单独启动着。
交换机也只是保留了商家的交换机。
启动测试
启动订单的微服务。
虽然注解很方便,但是它依赖containerFactory依赖admin 都在rabbitConfig内配置的。
spring boot 约定大于配置,其实我们是不需要写这么多的Bean类的。
amqp包和spring config集成。
把代码都注释掉
包含spring rabbitmq的一堆配置。
我们把之前配置的connectionFactory和rabbitAdmin都注释掉了。
重启项目测试
我们之前在这里用到了rabbitAdmin,这里我们先去掉,因为spring boot自动帮我们生成了一个rabbitAdmin。再运行项目
启动成功,说明已经连上rabbitMQ了。
postman发个消息
rabbitMQ这个类,基本没有用了 全被注释了
线程池这个类也用不到了
完整流程
首先在配置文件内配置
发消息直接自动注入rabbitTemplate
收消息在方法上加RabbitListener注解
设置这行代码都可以不需要
RabbitListener注解具体的实现。
开高级参数
这里发消息还用的是channel还需要改成rabbitTemplate