org.springframework.boot
spring-boot-starter-amqp
2.配置
在application.properties中添加RabbitMQ相关的配置
spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.88.150
spring.rabbitmq.port=5672
spring.rabbitmq.username=dpb
spring.rabbitmq.password=123
队列名称mq.queue.name=hello-queue
3.编写代码
目录结构
创建消息队列@Configuration
public class QueueConfig {
@Value("${mq.queue.name}")
private String queueName;
@Bean
public Queue createQueue(){
return new Queue(queueName);
}
}
创建消费者@Component
public class Receiver {
@RabbitListener(queues = “${mq.queue.name}”)
public void process(String msg){
System.out.println(“recevier:”+msg);
}
}
创建提供者@Component
public class Sender {
@Autowired
private AmqpTemplate rabbitAmqpTemplate;
@Value("${mq.queue.name}")
private String queueName;
public void send(String msg){
// 参数： 队列名称 和 消息内容
rabbitAmqpTemplate.convertAndSend(“hello-queue”,msg);
}
}
启动类@SpringBootApplication
public class SpringcloudRabbitmqDemoApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudRabbitmqDemoApplication.class, args);
}
}
单元测试@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringcloudRabbitmqDemoApplication.class)
public class SpringcloudRabbitmqDemoApplicationTests {
@Autowired
private Sender sender;
@Test
public void contextLoads() {
sender.send(“你好啊…”);
}
}
输出结果
