如果我們需要接收指定的訊息,可以通過直連型別的交換機實現,佇列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...