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!'
)
" [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
