springCloud + springBoot 中rabbitmq的使用
第一步: 首先要在springboot的配置文件中配置rabbitmq的信息
springCloud相当于一个微服务的生态系统,良好的支持了rabbitMq这个消息队列的应用
第二步: 使用spring自带包的几个类来完成消息发送者的封装
第三步:完成消息接受者/消费者的封装
大家注意这里的,sysMessageService使是我们项目中的消息保存到库的service,这个service中的addSysMessage是消息加库的方法,这里的参数sysMessageVo是封装的一个实体类,生产的消息,以实体类传输,消费方以实体类接收(对应数据库字段)
第四步:我们写一个测试的controller来测试一下:
这样就完成了一次的消息的生产和消费,建议在消费端消费数据的时候在方法上加上线程,这样数据量大了之后,才能更好的去消费消息.