1. 程式人生 > >rabbitmq(一)搭建以及建立簡單的程式碼例項

rabbitmq(一)搭建以及建立簡單的程式碼例項

使用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"); } }

完成