[工作模式(https://rabbitmq.com/getstarted.html)] 消息发布与订阅 (消费规则)
RabbitMQ 安装 使用 Docker 安装 RabbitMQ:
1 2 3 docker pull rabbitmq docker pull rabbitmq:3.11-management docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.11-management
启动成功：
1 2 3 4 5 6 7 2023-04-13 06:29:58.921971+00:00 [info] <0.867.0> started TCP listener on [::]:5672 completed with 4 plugins. 2023-04-13 06:29:59.143192+00:00 [info] <0.722.0> Server startup complete; 4 plugins started. 2023-04-13 06:29:59.143192+00:00 [info] <0.722.0> * rabbitmq_prometheus 2023-04-13 06:29:59.143192+00:00 [info] <0.722.0> * rabbitmq_management 2023-04-13 06:29:59.143192+00:00 [info] <0.722.0> * rabbitmq_web_dispatch 2023-04-13 06:29:59.143192+00:00 [info] <0.722.0> * rabbitmq_management_agent
进入终端操作 RabbitMQ：
1 docker exec -it rabbitmq /bin/bash
创建 Exchange 关系消息队列 这里采用 Publish/Subscribe 的工作模式，首先需要创建2个 Exchange：apiServices, dataServices,命令如下：
1 2 rabbitmqadmin declare exchange name=apiServices type =fanout rabbitmqadmin declare exchange name=dataServices type =fanout
创建用户：
1 rabbitmqctl add_user test test
给用户设置权限：
1 rabbitmqctl set_permissions -p / test ".*" ".*" ".*"
帮助文档：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 root@88344f80cbcb:/# rabbitmqadmin help subcommands Usage ===== rabbitmqadmin [options] subcommand where subcommand is one of: Display ======= list connections [<column>...] list channels [<column>...] list consumers [<column>...] list exchanges [<column>...] list queues [<column>...] list bindings [<column>...] list users [<column>...] list vhosts [<column>...] list permissions [<column>...] list nodes [<column>...] list parameters [<column>...] list policies [<column>...] list operator_policies [<column>...] list vhost_limits [<column>...] show overview [<column>...] Object Manipulation =================== declare exchange name=... type=... [auto_delete=... durable=... internal=... arguments=...] declare queue name=... [auto_delete=... durable=... arguments=... node=... queue_type=...] declare binding source=... destination=... [destination_type=... routing_key=... arguments=...] declare vhost name=... [tracing=...] declare user name=... password=... OR password_hash=... tags=... [hashing_algorithm=...] declare permission vhost=... user=... configure=... write=... read=... declare parameter component=... name=... value=... declare policy name=... pattern=... definition=... [priority=... apply-to=...] declare operator_policy name=... pattern=... definition=... [priority=... apply-to=...] declare vhost_limit vhost=... name=... value=... delete exchange name=... delete queue name=... delete binding source=... destination_type=... destination=... [properties_key=...] delete vhost name=... delete user name=... delete permission vhost=... user=... delete parameter component=... name=... delete policy name=... delete operator_policy name=... delete vhost_limit vhost=... name=... close connection name=... purge queue name=... Broker Definitions ================== export <file> import <file> Publishing and Consuming ======================== publish routing_key=... [payload=... properties=... exchange=... payload_encoding=...] get queue=... [count=... ackmode=... payload_file=... encoding=...] * If payload is not specified on publish, standard input is used * If payload_file is not specified on get, the payload will be shown on standard output along with the message metadata * If payload_file is specified on get, count must not be set
