1、添加包
1 <dependency> 2 <groupId>org.springframework.boot</groupId> 3 <artifactId>spring-boot-starter-amqp</artifactId> 4 </dependency>
2、添加链接字符串
#rabbitmq配置
spring.rabbitmq.addresses=xxxxx
spring.rabbitmq.username=xxxxx
spring.rabbitmq.password=xxxxxxx
spring.rabbitmq.virtual-host=xx
3、生产者,其中MSGRABBITQUERENAME为队列名称
1 @Component 2 public class RabbitProducer { 3 4 @Autowired 5 AmqpTemplate rabbitTemplate; 6 7 static final String MSGRABBITQUERENAME="chat.send.msg"; 8 9 public void sendMessages(String str) { 10 this.rabbitTemplate.convertAndSend(MSGRABBITQUERENAME,str); 11 } 12 }
4、消费者,我这里为手动确认模式,确保数据有效性。
1 @Component 2 @org.springframework.amqp.rabbit.annotation.RabbitListener(queues = "chat.send.msg") 3 public class RabbitListener { 4 5 @RabbitHandler 6 public void recieved(Message message, Channel channel) { 7 channel.basicAck(message.getMessageProperties().getDeliveryTag(), true); 8 } 9 }
然后直接调用就可以了