使用Python的Zato发送AMQP消息的教程
本 帮助主题 展示了使用Zato发送AMQP消息 所 需的内容. Zato 基于Python 的 为 SOA 、 云 集成 和 后端 服务 的 企业服务总线(ESB) 。
代码演示
下面是一些需要的代码:
from zato.server.service import Service
class MyService(Service):
def handle(self):
msg = 'My message'
conn_name = 'My CRM connection'
exchange_name = 'My exchange'
routing_key = ''
self.outgoing.amqp.send(msg, conn_name, exchange_name, routing_key)
理解连接定义和连接
在发送第一个消息之前，你必须让Zato知道要把消息发送到哪儿，因为默认情况下Zato支持分离生成消息的服务和消息送达的实际的目的地。
在你的代码里，你只是调用了单个.send方法，不需要真正地指定特定的URL或者凭证，消息过期时间，内容类型等等。你可以指定这些，不过你不需要。
这一切都通过连接定义和真正的连接来实现的。连接定义是一个说明连接到AMQP代理的所需要的详细信息的模板-代理的网络地址，虚拟主机名，用户名/密码以及类似的东西。每个连接定义可以用来创建一个或者多个处理要发送消息的细节-消息优先权，分发模式以及其他这个消息信息的连接。
这两种对象类型可以使用Zato的图形界面创建，也可以通过其它方法如enmasse或者API创建
图形界面
首先创建一个连接定义，然后用它来创建一个对外连接，就像下图所示：
总而言之，创建一个新连接和写一段前面所示的代码后，就可以热部署来发送AMQP消息了。
其它方式的配置
相反，或者说另外，使用enmasse工具和API同样可以创建，列出，更新或者删除AMQP连接。并不仅仅局限于图形界面方式。
更多使用示例
相关文章
这篇文章主要为大家介绍了Python的多任务进程，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助2022-01-01
在 Python 中，可以使用内置的 logging 模块来记录应用程序的信息,logging 模块还提供了一些高级功能，如日志回溯、日志轮换、日志缓冲等,需要的朋友可以参考下2023-04-04
这篇文章主要介绍了django-多对多表的创建和插入代码实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-09-09
有时在处理或打印一个PDF文档之前,你可能需要先知道该文档包含多少页,对于程序员来说,编写脚本来完成这项工作会更加高效,本文就介绍一个使用Python快速获取PDF文件页数的办法,需要的朋友可以参考下2024-03-03
Python TCP全连接攻击中SockStress全连接攻击详解
Sock Stress 全连接攻击属于TCP全连接攻击，因为需要建立一次完整的TCP三次握手，该攻击的关键点就在于，攻击主机将windows窗口缓冲设置为0，实现的拒绝服务2022-10-10
今天小编就为大家分享一篇Python GUI编程 文本弹窗的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-06-06
这篇文章主要介绍了python类的私有属性和公共属性说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-05-05
这篇文章主要为大家详细介绍了matplotlib实现区域颜色填充，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-03-03
这篇文章主要为大家介绍了Python列表常用的一些函数的使用详解，并通过一些简单的案例让大家更快的理解，感兴趣的可以跟随小编一起学习一下2021-12-12
Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统，专注于实时处理的异步任务队列，同时也支持任务调度。接下来通过本文给大家介绍Python中celery的使用详解，感兴趣的朋友一起看看吧2021-08-08
最新评论