rabbmitMQ 發布關鍵字模式 三

2021-10-22 14:39:24 字數 2027 閱讀 2618

import pika

import pika

# 輸入普通憑據(登入使用者名稱和密碼)

credentials = pika.

plaincredentials

('admin'

,'admin'

)# 輸入連線引數(阻塞連線)

connection = pika.

blockingconnection

( pika.

connectionparameters

('106.13.168.8'

, credentials=credentials)

)# 建立rabbit協議鏈結的通道

channel = connection.

channel()

# 宣告乙個名為logs的fanout型別的交換機

channel.

exchange_declare

(exchange=

'logs2'

, exchange_type=

'direct'

) #傳送引數 direct

# 傳送訊息內容

channel.

basic_publish

( exchange=

'logs2'

, routing_key=

'hello'

, body=

'hello world'

)print

('[x] sent hello world'

)connection.

close

()

import pika

# 輸入普通憑據(登入使用者名稱和密碼)

credentials = pika.

plaincredentials

('admin'

,'admin'

)# 輸入連線引數(阻塞連線)

connection = pika.

blockingconnection

( pika.

connectionparameters

('106.13.168.8'

, credentials=credentials)

)# 建立rabbit協議鏈結的通道

channel = connection.

channel()

# 宣告乙個名為logs的direct型別的交換機

channel.

exchange_declare

(exchange=

'logs2'

, exchange_type=

'direct'

)#指定傳送型別

# 繫結佇列

channel.

queue_declare

(queue=

'queue_name'

, exclusive=true)

# 將佇列繫結到交換機上

channel.

queue_bind

(exchange=

'logs2'

, queue=

'queue_name'

, routing_key=

'hello'

)def callback

(ch, method, properties, body)

:print

(" [x] %r"

% body)

# 宣告乙個名為logs的direct型別的交換機channel.

start_consuming()

channel.

basic_consume

(queue=

'queue_name'

, auto_ack=true, on_message_callback=callback)

channel.

start_consuming

()

Po模式和關鍵字模式

what?po模式 page object model 是一種設計思想,是為了解決自動化測試過程中隨著 量的增加導致的大量 難以維護 難以擴充套件 可讀性極差等災難性的事件的方案,所謂page object及頁面物件,頁面物件是哪些東西呢?比如乙個按鈕是乙個物件,乙個頁面也是乙個物件.實際的應用當中...

深入分析const關鍵字模型

頂層const和底層const const和其他關鍵字 最近在複習c primer,把以前沒注意到的都深入研究了一下。此篇部落格的結論都建立於c 11或者c 14的新標準上,編譯器為vs2015 community版本,g 可能會有較大出入 這點筆者已經在其他部落格上驗證 c語言中的巨集機制被繼承到...

hibernate多關鍵字模糊搜尋方法

1,與sql類似hql中也有左右連線和交叉連線,效果功能類似只是用法有稍微的差別,hql中不用on關鍵字,而是直接right join之前級聯的物件即可,如下 其中person與contact為一對多的關係,即乙個人有多個 的內容。再contact中有屬性person hql右連查詢,以右邊的為準查...