PYTHON CƠ BẢN - RẤT LÀ CƠ BẢN - Trang 77

import pika

connection

=

pika.BlockingConnection(pika.Connectio

nParameters(

'localhost'

))

channel

=

connection.channel()

channel.queue_declare(queue

=

'hello'

)

channel.basic_publish(exchange

=

''

, routing_key

=

'hel

lo'

, body

=

'Hello World!'

)

print

" [x] Sent 'Hello World!'"

connection.close()

ɇВKЮMQШXQIWWEKIGLɾRKXEG϶ROЎXRРMчЎRWIVZIVZɧ
OLEMFɨSQШXGLERRIPЮчɩ]PɧGLERRIPGɹXɱRPɧ

hello

7EYOLMOLEMFɨSGLERRIPXESXMЎRLɧRLKЮMQIWWEKIGɹ
RШMHYRK

Hello World!

XLɺRKUYEGLERRIPRɧ]OɯQXLIS

OLEMFɨS

routing_key

Pɧ

hello

6SYXMRK/I]WЌKMɾTчMАY

LšЪRKQIWWEKIRɧ]чЎRчɾRKGɨG[SVOIVчšвGOLEMFɨS
RLϼRQIWWEKIXLISVSYXMRKOI]'SRWYQIV

2LϼRQIWWEKI'SRWYQIV