RabbitMQ在Spring Boot中的使用步骤

<dependency>
<groupId>org.springframework.boot </groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

spring.rabbitmq.host =your_rabbitmq_host
spring.rabbitmq.port =5671
spring.rabbitmq.username =your_username
spring.rabbitmq.password =your_password

import org.springframework.stereotype.Component ;
import org.springframework.web.bind.annotation.ExceptionHandler ;
import org.springframework.web.bind.annotation.ResponseBody ;
import org.springframework.web.bind.annotation.RestController ;
import org.springframework.amqp.core.Message ;
import org.springframework.amqp.rabbit.annotation.RabbitListener ;
import org.springframework.stereotype.Component ;
@Component
public class RabbitMQListener {
@RabbitListener(queues = "someQueue")
public void listen(String message, Message amqpMessage) {
System.out.println ("Received message: " + message);
}
}

import org.springframework.beans.factory.annotation.Autowired ;
import org.springframework.stereotype.Service ;
import org.springframework.amqp.core.Message ;
import org.springframework.amqp.core.MessageProperties ;
import org.springframework.amqp.rabbit.core.RabbitTemplate ;
import org.springframework.stereotype.Service ;
@Service
public class RabbitMQService {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send消息(String exchange, String routingKey, String message) {
rabbitTemplate.convertAndSend (exchange, routingKey, message);
}
}

import org.springframework.context.annotation.Bean ;
import org.springframework.context.annotation.Configuration ;
import org.springframework.amqpConnectionFactory ;
import org.springframework.amqp.core  AmqpTemplate;
@Configuration
public class RabbitMQConfig {
@Bean
public AmqpTemplate rabbitTemplate() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setHost ("your_rabbitmq_host");
connectionFactory.setPort (5671);
connectionFactory.setUsername ("your_username");
connectionFactory.setPassword ("your_password");
return new AmqpTemplate(connectionFactory);
}
}

spring.rabbitmq.template.retry.enabled =true

  @Bean
  public Queue queue() {
return new Queue("myQueue", true);
  }