第一步：在spring boot项目中添加RabbitMq的maven依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
第二步：在配置文件中添加RabbitMq的配置
#配置RabbitMQ
spring.rabbitmq.host=192.168.1.103
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.publisherConfirms=true
第三步：添加RabbitMq配置类
import org.springframework.amqp.core.Queue;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.context.annotation.Bean;
@Configurable
public class RabbitMqConfig {
@Bean
public Queue countPalletBatchQueue(){
return new Queue("count-pallet-batch-queue");
};
}
第四步：添加生产者类
@Component
public class producter {
@Autowired
private AmqpTemplate amqpTemplate;
void create() {
String message = "这是一条消息";
amqpTemplate.convertAndSend("count-pallet-batch-queue",message);
}
}
第五步：添加消费者类
@Component
@Service
@Transactional
public class customer {
@Autowired
private AmqpTemplate amqpTemplate;
@RabbitListener(queues = "count-pallet-batch-queue")
public String custom(String message){
return message;
}
}