?在上面這張圖中，我們可以看到 X 綁定了兩個(gè)隊(duì)列，綁定類型是 direct。隊(duì)列 Q1 綁定鍵為 orange， 隊(duì)列 Q2 綁定鍵有兩個(gè):一個(gè)綁定鍵為 black，另一個(gè)綁定鍵為 green.

在這種綁定情況下，生產(chǎn)者發(fā)布消息到 exchange 上，綁定鍵為 orange 的消息會(huì)被發(fā)布到隊(duì)列
Q1。綁定鍵為 blackgreen 和的消息會(huì)被發(fā)布到隊(duì)列 Q2，其他消息類型的消息將被丟棄。

多重綁定

?當(dāng)然如果 exchange 的綁定類型是direct，但是它綁定的多個(gè)隊(duì)列的 key 如果都相同，在這種情況下雖然綁定類型是 direct 但是它表現(xiàn)的就和 fanout 有點(diǎn)類似了，就跟廣播差不多，如上圖所示。

實(shí)戰(zhàn)

?生產(chǎn)者

public class DirectLogs {// 交換機(jī)的名稱public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String message = scanner.next();channel.basicPublish(EXCHANGE_NAME,"info",null,message.getBytes(StandardCharsets.UTF_8));System.out.println("生產(chǎn)者發(fā)出的消息："+ message);}} }

消費(fèi)者

public class ReceiveLogsDirect01 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMqUtils.getChannel();//聲明一個(gè)隊(duì)列channel.queueDeclare("console",false,false,false,null);//綁定交換機(jī)與隊(duì)列channel.queueBind("console",EXCHANGE_NAME,"info");channel.queueBind("console",EXCHANGE_NAME,"warning");DeliverCallback deliverCallback = (consumerTag, message) -> {System.out.println("ReceiveLogsDirect01控制臺(tái)打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume("console",true,deliverCallback,consumerTag -> {});} } public class ReceiveLogsDirect02 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMqUtils.getChannel();//聲明一個(gè)隊(duì)列channel.queueDeclare("disk",false,false,false,null);//綁定交換機(jī)與隊(duì)列channel.queueBind("disk",EXCHANGE_NAME,"error");DeliverCallback deliverCallback = (consumerTag, message) -> {System.out.println("ReceiveLogsDirect02控制臺(tái)打印接受到的消息：" + new String(message.getBody()));};channel.basicConsume("disk",true,deliverCallback,consumerTag -> {});} }

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ direct交换机的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。