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

发布于 2016-01-20 07:46:56 | 199 次阅读 | 评论: 0 | 来源: 网友投递

Python编程语言

Python 是一种面向对象、解释型计算机程序设计语言，由Guido van Rossum于1989年底发明，第一个公开发行版发行于1991年。Python语法简洁而清晰，具有丰富和强大的类库。它常被昵称为胶水语言，它能够把用其他语言制作的各种模块（尤其是C/C++）很轻松地联结在一起。

这篇文章主要介绍了使用Python的Zato发送AMQP消息的教程,主要是基于一些Zato的图形化界面进行操作,需要的朋友可以参考下

本帮助主题展示了使用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创建