RabbitMQ Service Connection test python

RabbitMQ Cluster 구성 후 서비스를 테스트하기 위해

간단한 프로그램을 만들어봤다.

(RabbitMQ Cluster를 구성하는 방법은 맨 아래 링크를 걸어놨으니

참고하시길 바란다)

 

Rabbitmq 접속 테스트 소스(python 기준)

- 접속 시 vhost를 지정하지 않으면 default로 / 로 접속

- PlainCredentials 부분에는 클러스터 생성 시 만들었던 계정 id, pw를 입력
- url 부분은 ip로 하면 접속이 안되고 도메인을 사용해야 한다.

 

RabbitMQ 서비스 접속 테스트 코드

import pika

class Publisher:
    def __init__(self):
        
        self.__url = '{domain}'
        self.__port = 5672
        self.__vhost = '{vhost_name}'
        self.__cred = pika.PlainCredentials('{id}', '{pw}')
        
        return

    def main(self):
        conn = pika.BlockingConnection(pika.ConnectionParameters(self.__url, self.__port, self.__vhost, self.__cred))
        chan = conn.channel()
        # chan.basic_publish(
        #     exchange = '',
        #     routing_key = self.__queue,
        #     body = 'Hello RabbitMQ'
        # )
        conn.close()
        return

publisher = Publisher()
publisher.main()

 

 

RabbitMQ Cluster 구성 방법

 

https://babbeolicoding.tistory.com/38

RabbitMQ Cluster 구성하기