使用 RabbitMQ 的详细步骤(elixir版本)

启动 rabbitmq 服务

在安装好 rabbitmq 之后, 运行:

su # 进入root权限
rabbitmqctl start_app

打开浏览器 http://localhost:15672/#/ , 就可以看到rabbitmq的管理界面了. 默认账号 guest, 密码 guest.

使用amqp

amqp 是 elixir 版本的 rabbitmq 客户端.

在 elixir 项目中添加依赖: {:amqp, "~> 1.0.0-pre.1"}, 你也可以到hex.pm上查找更稳定的版本.

建立稳定的 rabbitmq 连接

+----------break--------------+
          |                             |
          |                             |
         +v-------+            +--------+----+
+------->+ connect+--success-->+  connected  |
|        +----+---+            +-------------+
|             |
+----fail-----+

我们需要一个可以在连接断开之后自动重连的机制, 可以用一个 gen_server 来实现.