使用Python的Zato发送AMQP消息的教程

站长资源 2024/11/24 佚名

2 0 1

本帮助主题展示了使用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连接。并不仅仅局限于图形界面方式。
更多使用示例

请浏览全部API，以及更多AMQP使用示例请查看这里。

Python

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！

评论“使用Python的Zato发送AMQP消息的教程”

暂无评论...

《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线

暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。

艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒经典版》的玩家都可以获得奖励。

更新日志

2024年11月24日

使用Python的Zato发送AMQP消息的教程

使用Python装饰器在Django框架下去除冗余代码的教程

scrapy自定义pipeline类实现将采集数据保存到mongodb的方法

评论“使用Python的Zato发送AMQP消息的教程”

《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线

更新日志

友情链接