WMQX 是一个基于 RabbitMQ 开发的支持 http 协议的 MQ 消息推送服务, 他的前身是 wmq, 由于在代码架构、实现方式上区别较大，所以新建了项目叫 WMQX，在此感谢他的作者同时也是我的好友 snail007, 当然，你也可以理解为 WMQX 是 wmq 的升级版。
RabbitMQ 是一个轻量级的，易于部署在本地和云上，支持多个消息传递协议的消息队列中间件。RabbitMQ 可以应用于许多的场景中，同时也支持多种语言的 SDK。通常你会这样使用 RabbitMQ：
- 作为生产者：
- 编写代码连接到 RabbitMQ，并打开一个 channel。
- 编写代码声明一个 exchange，并设置相关属性。
- 编写代码声明一个 queue，并设置相关属性。
- 编写代码使用 routing key，在 exchange 和 queue 之间建立好绑定关系。
- 编写代码发送消息到 RabbitMQ。
- 作为消费者：
- 编写代码连接到 RabbitMQ，并打开一个 channel, 开启消费进程，等待接收到消息后，处理消费的业务逻辑。
如下图所示：
- RabbitMQ 的连接、Exchange、Queue 的声明和修改和业务代码耦合在一起，增加了开发和维护的成本。
- 当修改消费者的业务逻辑，可能会需要频繁的重启消费进程。
- 对于第一次使用 MQ 的用户，去理解 RabbitMQ 的原理和编写代码实现生产和消费是需要一定的时间和人力成本。
- 。。。
- 将 RabbitMQ 的连接、Exchange、Queue 的声明和修改删除等一些和业务无关的操作抽离出来单独提供服务，Exchange、queue 的操作以友好的 API 的方式提供给用户。
- 帮助用户去实现每一个消息的消费进程，用户只需要提供消费者的 API 接口，消费进程等待有消息后调用对应的消费者 API。消费者业务逻辑修改，只需要修改 API, 消费进程无需重启。
- 对于第一次使用 MQ 或者不清楚 RabbitMQ 原理的用户，不需要去深入了解 RabbitMQ 的使用和编码实现，只需要通过 http 的方式接入服务，即可快速使用消息队列。
所以 WMQX 也就由此诞生。工作原理如下图所示：
- 无需连接 RabbitMQ，提供高性能，高可用的 http 接口来对消息进行管理
- 帮助用户实现消费进程，只需要通过接口添加对应的消费者 api 即可实现消费或消息推送
- 每一个消费者由单独的 goroutine 处理，消费者相互独立消费
- 部署简单方便，支持跨平台部署，使用和接入成本低
- 通过 http 的发布接口发送消息，WMQX 消费进程将原始请求信息转发到对应的消费者URL
- 提供一套完善的后台管理 UI, 项目 WMQX-UI
如果你没有 RabbitMQ 服务的话，你需要自行安装，安装方法非常简单， http://www.rabbitmq.com/download.html
下载最新的二进制程序，https://github.com/phachon/wmqx/releases
# 解压
$ tar -zxvf wmqx-linux-amd64.tar.gz# 默认的配置文件使用当前目录下的 wmqx.conf
$ cp config.toml wmqx.toml
# 配置 wmqx.conf
[rabbitmq]
host = "RabbitMQ Server Ip"
port = 5672
username = "test"
password = "123456"
vhost = "/"
# 启动
$ ./wmqx
# 当然，你也可以指定配置文件路径启动
$ ./wmqx --conf wmqx.conf
- 如果您喜欢该项目，请 Star.
- 如果在使用过程中有任何问题， 请提交 Issue.
- 如果您发现并解决了bug，请提交 Pull Request.
- 如果您想二次开发，欢迎 Fork.
- 如果你想交个朋友，欢迎发邮件给 [email protected].
MIT
Create By [email protected]