咱們在consumer這個功能下進行代碼的編寫
首先是新建這個層級的包
建立入門程序的消費者
消費者也須要和mq創建通道。創建鏈接建立通道
在頂部都聲明這個隊列
下面寫核心代碼監聽隊列。basicConsume方法這就是核心方法
Ctrl+T--選擇最後一個PublisherCallbackChannelImpl
有不少的重載方法,咱們取其中的一個
測試
這裏用原始的消費方法
這個裏面須要重寫方法
handleDelivery
當接收到消息後就會調用hanleDelivery
滴一個參數consumerTag在實現類的方法裏面有一個地方是設置這個consumerTag 也就是消費者標籤的地方。這個參數是可設也可不設置的
經過envelope是信封 的意思。經過envelope能夠拿到不少東西例如拿到交換機
還能夠拿到消息Id
參數列表 各個參數的意思
輸出消息的內容
把channel定義在try catch的外面
3d
若是再次執行一次 發送的方法。
那麼接收的這裏也會自動接收消息
blog