rabbitmq(一)搭建以及建立簡單的程式碼例項
阿新 • • 發佈:2018-11-01
使用Docker搭建的rabbitMq
docker pull
拉取映象
docker pull rabbitmq:management
啟動映象
docker run -d --name rabbitmq
-p 5671:5671 -p 5672:5672 -p 4369:4369 -p 25672:25672 -p 15671:15671 -p 15672:15672 rabbitmq:management
為什麼會有這麼多埠 是因為映象本身也是有這麼多埠的 只是在啟動引數的時候寫上去了
訪問 IP:15672
出現如下介面 搭建完成
搭建java簡單的示例專案
springboot
目錄結構
專案配置
application.yml:
spring:
application:
name: liao
rabbitmq:
host: 127.0.0.1
port: 5672
username: 123
password: 123456
QueueConfig.java
//在類頭上記得加@Configuration
@Bean
public Queue createQueue(){
return new Queue("hello-queue");
}
接收佇列
Receiver.java
//監聽多個佇列
//@RabbitListener(queues = {"hello-queue1","hello-queue2"})
@RabbitListener(queues = "hello-queue")
public void process(User msg){
System.out.println("接受到了訊息:"+msg);
}
傳送訊息
Send
@Autowired
private AmqpTemplate amqpTemplate;
public void send(User msg){
amqpTemplate.convertAndSend("hello-queue",msg);
}
Test
@RunWith(SpringRunner.class)
@SpringBootTest(classes =SpringcloudMqApplication.class )
public class SpringcloudMqApplicationTests {
@Autowired
private Send send;
@Test
public void contextLoads() {
User user=new User(); user.setId(1L); user.setUsername("yjakly"); } }
完成