PikaBus 1.3.4

特点

• 默认情况下启用amqp的安全消息传递，包括：

  • 所有节点上的持久队列和镜像队列。在
  • 持久消息，这意味着节点重新启动后不会丢失任何消息。在
  • 用RabbitMq publisher confirms确认交货。在
  • 至少保证一次交货。在

  在
• 面向对象的API，界面简洁易用。在
• 容错，自动重新连接重试逻辑和状态恢复。在

安装

pip install PikaBus

示例

快速入门

克隆PikaBus回购：

git clone https://github.com/hansehe/PikaBus.git

使用Docker启动本地RabbitMq实例：

docker run -d --name rabbit -e RABBITMQ_DEFAULT_USER=amqp -e RABBITMQ_DEFAULT_PASS=amqp -p 5672:5672 -p 15672:15672 rabbitmq:3-management

在以下位置打开RabbitMq admin（user=amqp，密码=amqp）：

http://localhost:15672/

然后，运行示例：

pip install PikaBus
python ./Examples/basic_example.py

尝试重新启动RabbitMq以注意PikaBus如何容忍停机时间：

docker stop rabbit
docker start rabbit

向正在运行的PikaBus使用者发送或发布更多消息：

python ./Examples/send_example.py
python ./Examples/publish_example.py

贡献

• 问题跟踪者：https://github.com/hansehe/PikaBus/issues
• 源代码：https://github.com/hansehe/PikaBus

许可证

这个项目是根据麻省理工学院的许可证授权的。在

版本控制

此软件遵循Semantic Versioning