Python Rabbitmq 사용 (3)

위 기사에서는 작업 대기열에 대해 설명합니다. 각 메시지는 수신자 중 한 명에게만 전송됩니다. 모든 수신자가 메시지를 수신할 수 있도록 메시지를 브로드캐스트해야 하는 경우 스위치를 사용해야 합니다.

스위치의 작동 원리: 메시지 송신 측이 먼저 메시지를 스위치로 보내고, 스위치는 메시지를 바인딩된 메시지 큐로 보낸 다음 각 수신 측에서는 해당 메시지 대기열에서 정보를 수신할 수 있습니다.

rabbitmq 스위치의 작동 원리

다음은 send.py와 receive.py를 사용하여 다음의 기능을 시뮬레이션합니다. 스위치. send.py는 송신측을 나타내고 receive.py는 수신측을 나타냅니다.

receive.py 코드 분석

첫 번째 기사의 receive.py와 비교하면 주로 두 가지 변경 사항을 수행합니다.

스위치 정의
hello 대기열을 사용하는 대신 임시 대기열이 무작위로 생성되어 스위치

#!/usr/bin/env python
#coding=utf8
import pika
connection= pika.BlockingConnection(pika.ConnectionParameters(
'localhost'))
channel= connection.channel()
#定义交换机
channel.exchange_declare(exchange='messages',type='fanout')
#随机生成队列，并绑定到交换机上
result= channel.queue_declare(exclusive=True)
queue_name= result.method.queue
channel.queue_bind(exchange='messages', queue=queue_name)
def callback(ch, method, properties, body):
print " [x] Received %r" % (body,)
channel.basic_consume(callback, queue=queue_name, no_ack=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
channel.start_consuming()

에 바인딩됩니다. 위의 예제 코드에서 매개변수는 queue_declare isclusive =True는 수신 측이 종료할 때 임시로 생성된 대기열이 파괴되어 리소스가 점유되지 않음을 의미합니다. 이 프로그램을 실행한 후 Rabbitmqctl list_exchanges 명령을 사용하여 스위치 정보를 확인합니다.

rabbitmq 스위치 정보 보기

여기서 빨간색 프레임은 위의 예에서 정의된 스위치입니다. 그런 다음 Rabbitmqctl list_queues를 사용하여 메시지 대기열 상황을 확인합니다.

rabbitmq 대기열 정보 보기

빨간색 상자는 무작위입니다. 생성된 메시지 큐.

send.py 코드 분석

첫 번째 기사의 send.py와 비교하면 두 가지만 변경했습니다. :

교환 정의
메시지를 hello 큐로 보내는 대신

#!/usr/bin/env python
#coding=utf8
import pika
connection= pika.BlockingConnection(pika.ConnectionParameters(
'localhost'))
channel= connection.channel()
#定义交换机
channel.exchange_declare(exchange='messages',type='fanout')
#将消息发送到交换机
channel.basic_publish(exchange='messages', routing_key='', body='Hello World!')
print " [x] Sent 'Hello World!'"
connection.close()

교환으로 보냅니다. 위 예제 코드에서 basic_publish 메소드의 매개변수 교환은 다음과 같습니다. 해당 스위치는 이를 브로드캐스트하여 모든 대기열에 보내야 하므로 Routing_key를 설정할 필요가 없습니다.

exchange가 비어 있으면 익명 스위치를 사용한다는 의미입니다. 위 스위치 정보 사진을 보면 amq.*와 같은 스위치가 있는 것을 알 수 있습니다. 이는 시스템의 기본 스위치입니다. Routing_key는 익명 스위치를 사용할 때만 지정하면 되며 어느 큐로 전송되는지를 나타냅니다. 첫 번째 문서의 예에서는 이 기능을 보여줍니다.

다른 터미널을 열고 send.py를 실행하면 receive.py가 메시지를 수신한 것을 확인할 수 있습니다. 여러 터미널이 receive.py를 실행하는 경우 각 receive.py는 메시지를 수신합니다.

위는 Python Rabbitmq(3)을 사용한 내용입니다. 더 많은 관련 내용은 PHP 중국어 홈페이지(m.sbmmt.com)를 참고해주세요!