direct直連模式

2021-08-04 19:08:15 字數 879 閱讀 7581

如果我們需要接收指定的訊息,可以通過直連型別的交換機實現,佇列1、2將僅接受key1的訊息,而佇列3、4將接收key2的訊息。

生產者:

public class producer ;

public static void main(string argv) throws exception

channel.close();

connection.close();}}

消費者1:

public class consumer01 ;

public static void main(string argv) throws exception

consumer consumer = new defaultconsumer(channel)

};channel.basicconsume(queuename, true, consumer);}}

消費者2

public class consumer02 ;

public static void main(string argv) throws exception

consumer consumer = new defaultconsumer(channel)

};channel.basicconsume(queuename, true, consumer);}}

這裡生產者產生的訊息分別放到了兩個佇列中,佇列1中的訊息被消費了並不影響另外乙個佇列中的訊息。

直連mysql Python直連MySQL資料庫

python標準資料庫介面為python db api,python db api為開發人員提供了資料庫應用 程式設計介面。python 資料庫介面支援非常多的資料庫,你可以選擇適合你專案的資料庫 gadfly msql mysql postgresql microsoft sql server 2...

RabbitMQ之Direct交換器模式開發

dirtct交換器,即發布與訂閱模式,匹配規則為完全匹配。配置檔案 2 spring.rabbitmq.host 192.168.50.30 3 spring.rabbitmq.port 5672 4 spring.rabbitmq.username rabbit 5 spring.rabbitmq...

rabbitmq直連模式 消費者

pom org.springframework.boot spring boot starter amqp org.springframework.boot spring boot starter web org.springframework.boot spring boot starter te...