Python에서 RabbitMQ를 처음 운영한 경험 (1)

Python을 사용하여 CDN의 콘텐츠와 운영 상태를 관리하고 모니터링하는 분산 시스템을 구현하고 싶었기 때문에 우연히 RabbitMQ를 알게 되었습니다. Yu Feng의 "왜 RabbitMQ를 선택해야 할까요?" " 등등.

MQ라는 단어가 눈에 들어오자 MQ가 무엇인지, 즉 메시지 큐(Message Queue)가 무엇인지 몇 시간씩 읽어보았습니다. 이름에서 알 수 있듯이 메시지 큐, 메시지로 채워진 큐, 큐, 데이터 구조 명사는 선입선출 특성을 갖는 데이터 구조입니다. 메시지 큐는 메시지를 전달하는 데 사용되는 것에 지나지 않습니다. 그러면 그 중요성은 무엇인지, 응용 시나리오는 무엇인지, 어떤 기능이 있는지, 고유한 장점은 무엇인지, 왜 사용해야 하는지에 대한 일련의 질문이 있습니다. 내 마음에.

많은 검색 끝에 메시지 큐가 애플리케이션 간 정보 전송을 위한 통신 방법이라는 것을 피상적으로 이해하게 되었습니다. 예를 들어 여러 서버의 로그를 분석해야 하는 경우 각 서버에서 하나의 프로세스를 사용하여 데이터, 즉 필요한 정보를 Mysql 데이터베이스의 테이블에 쓴 다음 여러 프로세스를 작성하여 데이터를 읽을 수 있습니다. 분석은 그다지 좋지 않지만 곧 이 디자인의 추악함이 드러났습니다... 처리를 위해 여러 프로그램이 대기열에서 데이터를 가져오길 원하십니까? 문제 없습니다. 우리는 프로그램 수를 하드코딩했습니다...무엇이요? 또한 압력이 동적으로 증가하거나 감소함에 따라 프로그램이 동적으로 압력을 분배하도록 허용하시겠습니까? 이것은 매우 인기 있는 "RabbitMQ+Python 클래식 토끼 및 토끼 둥지 소개"의 예입니다. 생각해 보세요. 내 CDN이 많은 데이터를 전송하면 데이터 배포, 처리 등 모든 것이 문제가 됩니다. 하지만 나는 아직도 Rabbit이 이러한 것들을 어떻게 구현하는지 이해하지 못합니다.

개념적으로 말하면 RabbitMQ는 AMPQ(Advanced Message Protocol Queuing)의 표준 구현입니다. AMQP에 익숙하지 않은 사람은 RabbitMQ 문서를 이해하지 못할 것이라고 합니다. 그러나 우리는 핵심 개념에 대한 강력한 이해만을 구축할 수 있습니다. 전체 RabbitMQ 구현 원칙 모델은 아래 그림에 나와 있습니다. 이는 실제로 라우팅 작업 배포 대기열이 있는 생산자 및 소비자 모델입니다. 그림에서 볼 수 있듯이 생산자는 해당 정보를 생성하여 라우터로 보냅니다. 라우터는 정보의 핵심 정보를 기반으로 정보를 다른 메시지 대기열에 배포한 다음 소비자는 다른 메시지 대기열의 데이터를 읽습니다.

브로커: 간단히 말하면 메시지 대기열 서버 엔터티입니다.
교환: 어떤 메시지가 어떤 대기열로 라우팅되는지에 따라 규칙을 지정하는 메시지 교환입니다.
큐: 메시지 큐 전달자, 각 메시지는 하나 이상의 큐에 배치됩니다.
바인딩: 바인딩, 그 기능은 라우팅 규칙에 따라 Exchange와 대기열을 바인딩하는 것입니다.
라우팅 키: 라우팅 키워드, Exchange는 이 키워드를 기반으로 메시지를 전달합니다.
vhost: 가상 호스트. 여러 사용자의 권한을 분리하기 위해 브로커에서 여러 가상 호스트를 열 수 있습니다.
프로듀서(Producer): 메시지 프로듀서는 메시지를 전달하는 프로그램입니다.
소비자: 메시지 소비자는 메시지를 받아들이는 프로그램입니다.
채널: 클라이언트의 각 연결에서 여러 채널을 설정할 수 있으며 각 채널은 세션 작업을 나타냅니다.

메시지 큐를 사용하는 과정은 대략 다음과 같습니다.

(1) 클라이언트는 메시지 큐 서버에 접속하여 채널을 오픈합니다.
(2) 클라이언트는 교환을 선언하고 관련 속성을 설정합니다.
(3) 클라이언트는 대기열을 선언하고 관련 속성을 설정합니다.
(4) 클라이언트는 라우팅 키를 사용하여 Exchange와 대기열 간의 바인딩 관계를 설정합니다.
(5) 클라이언트는 교환할 메시지를 전달합니다.

RabbitMQ의 일반적인 프로세스와 장점을 이해한 후, 자체 Fedora에서 RabbitMQ를 사용해 보기 시작했습니다.

RabbitMQ 공식 홈페이지에 따르면 설치는 여기

http://www.rabbitmq.com/download.html

바이너리 패키지의 각 버전을 다운로드하려면 클릭하세요. 나는 Rabbitmq-server-3.3.0-1.noarch.rpm을 다운로드했습니다.

다운로드에 들어갑니다. 경로, /home/ sun5495/Downloads/

[sun5495@localhost Downloads]# sudo chmod 777 Rabbitmq-server-3.3.0-1.noarch.rpm

실행 파일 권한을 변경하고 실행 권한을 높입니다.

그런 다음 ./rabbitmq-server-3.3.0-1.noarch.rpm을 실행하면 실행 시 오류가 보고되고 설치할 수 없습니다.

지금 Erlang을 설치해야 한다는 사실이 밝혀졌습니다. yum install erlang 명령을 실행해 보세요.

그런 다음 루트 사용자를 사용하여

rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc yum install rabbitmq-server-3.3.0-1.noarch.rpm

를 실행하면 설치가 성공적으로 완료됩니다.

RBMQ를 시작하도록 설정하려면 관리자 계정을 사용하여

chkconfig rabbitmq-server on

를 실행하고

/sbin/service rabbitmq-server stop/start

명령을 사용하여 서버를 열고 닫으면 됩니다. 전원을 켜면 다음 오류가 보고됩니다

rabbitmq-server 시작(systemctl을 통해):rabbitmq-server.service에 대한 작업이 실패했습니다. 자세한 내용은 'systemctl status Rabbitmq-server.service' 및 'journalctl -xn'을 참조하세요. . [실패]

使用journalctl -xn命令打开日志，查看了下貌似是Erlang的某个文件拒绝访问，然后还提出了一大堆建议。

尝试一下

grep beam.smp /var/log/audit/audit.log | audit2allow -M mypolsemodule -i mypol.pp/sbin/service rabbitmq-server start

既然RabbitMQ安装也运行成功了，那么我就来尝尝RabbitMQ的鲜吧。就从官网上的例子一步一笔来做好了。

由于我使用的是Python，那么就需要安装一些支持RabbitMQ的库来进行操作，其中包括

py-amqplib,txAMQP,pika这几种，按照官网的tutorial，我也安装了pika。

pip install pika

从最简单的收发消息开始。即一端发送消息，一端接收消息。

发送方即生产者，首先要创建与RabbitMQ服务器的连接，

#!/usr/bin/env pythonimport pikaconnection = pika.BlockingConnection(pika.ConnectionParameters(              
 'localhost'))channel = connection.channel()

此处服务器连接本地localhost，也可以指定ip或者主机名。

其次发送方需要声明一个队列，比如命名为sayhello

channel.queue_declare(queue='sayhello')

此时我们就可以发送消息了。由于第一个小案例比较简单，没有经过路由器，因此发送消息时，指定路由为空即可。

channel.basic_publish(exchange='',                        
routing_key='hello',                                    
body='hello world')print "Sent ‘hello world'"

最后关闭连接即可。

connection.close()

接收方即消费者，需要从队列上获取数据，因此也需要绑定一个队列

channel.queue_declare(queue='hello')

同时，由于接收方的工作方式是基于队列的消息执行一个回调函数，当收到消息时，Pika就会执行相应的回调函数，因此我们需要定义此函数。

def callback(ch, method, properties, body):    print " [x] Received %r" % (body,)

接下来我们需要初始化这个消费者，并对消费者进行启动。

channel.basic_consume(callback,                      
queue='hello',                      
no_ack=True)print ' [*] Waiting for messages. To exit press CTRL+C'channel.start_consuming()

OK执行成功。

接下来就逐步的深入体验RabbitMQ的独特魅力。

以上就是Python操作RabbitMQ初体验（一）的内容，更多相关内容请关注PHP中文网（www.php.cn）！