이번 목차는 Topics 에 대한 내용입니다.
이전 소단원에서는 diret exchange를 이용하여 선택적으로 로그를 수신 할 수 있게 하였습니다. diret exchange을 사용하여 시스템을 개선 되었지만 여전히 한계가 있습니다. 여러 기준에 따라 routing을 수행 할 수 없습니다.
해당 소단원에서는 심각도와 기능을 기반으로 로그를 라우팅하는 unix의 svslog 처럼 사용하기 위해 topic을 사용 할 예정입니다.
- Topic exchange
Topic exchange로 전송된 메시지는 임의의 라우팅 키를 가질 수 없습니다. 점(.) 으로 구분된 단어 목록이어야 합니다. 단어는 무엇이든 될 수 있지만 일반적으로 메시지와 연결된 일부 기능을 지정합니다.
바인딩 키도 같은 형식이어야 합니다. Topic exchange의 논리는 direct exchange와 유사합니다. 특정 라우팅 키로 보낸 메시지는 일치하는 바인딩 키로 바인딩 된 모든 큐에 전달합니다. 그러나 바인딩 키에는 두 가지의 특별한 경우가 있습니다.
| * : 한 단어만을 지정 가능 # : 한 단어 이상을 지정 가능 |
위와 같이 어떤 토픽이냐에 따라 해당 토픽에 관심이 있는 Sonsumer에게 메시지를 선별젹으로 보내게 됩니다.
예를 들어, *.orange.*의 경우 a.orange.b 형식으로 매칭되고, a.b.orange는 매칭되지 않습니다. 또한 lazy.# 경우 lazy.aa.bb 혹읜 lazy.cc.dd 혹시 lazy.abcd.beee 모두와 매칭 됩니다.
1.2.5.1. Python
- Python 소스 코드 작성
receive_log_topic.py
| #!/usr/bin/env python import pika import sys connection = pika.BlockingConnection( pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='topic_logs', exchange_type='topic') result = channel.queue_declare('', exclusive=True) queue_name = result.method.queue binding_keys = sys.argv[1:] if not binding_keys: sys.stderr.write("Usage: %s [binding_key]...\n" % sys.argv[0]) sys.exit(1) for binding_key in binding_keys: channel.queue_bind( exchange='topic_logs', queue=queue_name, routing_key=binding_key) print(' [*] Waiting for logs. To exit press CTRL+C') def callback(ch, method, properties, body): print(" [x] %r:%r" % (method.routing_key, body)) channel.basic_consume( queue=queue_name, on_message_callback=callback, auto_ack=True) channel.start_consuming() |
emit_log_topic.py
| #!/usr/bin/env python import pika import sys connection = pika.BlockingConnection( pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='topic_logs', exchange_type='topic') routing_key = sys.argv[1] if len(sys.argv) > 2 else 'anonymous.info' message = ' '.join(sys.argv[2:]) or 'Hello World!' channel.basic_publish( exchange='topic_logs', routing_key=routing_key, body=message) print(" [x] Sent %r:%r" % (routing_key, message)) connection.close() |
- Message Queue테스트
# 모든 메시지 허용
| mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "#" [*] Waiting for logs. To exit press CTRL+C mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "test" "test" [x] Sent 'test':'test' mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "#" [*] Waiting for logs. To exit press CTRL+C [x] 'test':b'test' |
# 커널 로그 전부 받기
| mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "kern.*" [*] Waiting for logs. To exit press CTRL+C mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "kern.warn" "kernel warnning log" [x] Sent 'kern.warn':'kernel warnning log' mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "kern.*" [*] Waiting for logs. To exit press CTRL+C [x] 'kern.warn':b'kernel warnning log' |
# critical 로그 받기
| mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "*.critical" [*] Waiting for logs. To exit press CTRL+C mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "kern.critical" "critical log" [x] Sent 'kern.critical':'critical log' mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "*.critical" [*] Waiting for logs. To exit press CTRL+C [x] 'kern.critical':b'critical log' |
# 여러 바인딩 로그 받기
| mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "kern.*" "*.critical" [*] Waiting for logs. To exit press CTRL+C ---------------- mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "kern.test" "first message" [x] Sent 'kern.test':'first message' mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "test.critical" "Second message" [x] Sent 'test.critical':'Second message' mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "kern.critical" "Third message" [x] Sent 'kern.critical':'Third message' mwno@mwno-VirtualBox:/product/python$ python3 emit_log_topic.py "critical.kern" "no message" [x] Sent 'critical.kern':'no message' ---------------- mwno@mwno-VirtualBox:/product/python$ python3 receive_log_topic.py "kern.*" "*.critical" [*] Waiting for logs. To exit press CTRL+C [x] 'kern.test':b'first message' [x] 'test.critical':b'Second message' [x] 'kern.critical':b'Third message' |
'오픈소스 > RabbitMQ' 카테고리의 다른 글
| RabbitMQ Tutorials - RPC (8) (0) | 2022.04.04 |
|---|---|
| RabbitMQ Tutorials - Routing (6) (0) | 2022.04.04 |
| RabbitMQ Tutorials - Publish/Subscribe (5) (0) | 2022.04.04 |
| RabbitMQ Tutorials - Work queues (4) (0) | 2022.04.04 |
| RabbitMQ Tutorials - Hello Wolrd (3) (0) | 2022.04.04 |