快捷導(dǎo)航

使用Python的Zato發(fā)送AMQP消息的教程

更新時(shí)間：2015年04月16日 11:50:12 投稿：goldensun

這篇文章主要介紹了使用Python的Zato發(fā)送AMQP消息的教程,主要是基于一些Zato的圖形化界面進(jìn)行操作,需要的朋友可以參考下

本幫助主題展示了使用Zato發(fā)送AMQP消息所需的內(nèi)容. Zato 基于Python 的為 SOA 、云集成和后端服務(wù) 的企業(yè)服務(wù)總線(xiàn)(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)

理解連接定義和連接

在發(fā)送第一個(gè)消息之前，你必須讓Zato知道要把消息發(fā)送到哪兒，因?yàn)槟J(rèn)情況下Zato支持分離生成消息的服務(wù)和消息送達(dá)的實(shí)際的目的地。

在你的代碼里，你只是調(diào)用了單個(gè).send方法，不需要真正地指定特定的URL或者憑證，消息過(guò)期時(shí)間，內(nèi)容類(lèi)型等等。你可以指定這些，不過(guò)你不需要。

這一切都通過(guò)連接定義和真正的連接來(lái)實(shí)現(xiàn)的。連接定義是一個(gè)說(shuō)明連接到AMQP代理的所需要的詳細(xì)信息的模板-代理的網(wǎng)絡(luò)地址，虛擬主機(jī)名，用戶(hù)名/密碼以及類(lèi)似的東西。每個(gè)連接定義可以用來(lái)創(chuàng)建一個(gè)或者多個(gè)處理要發(fā)送消息的細(xì)節(jié)-消息優(yōu)先權(quán)，分發(fā)模式以及其他這個(gè)消息信息的連接。

這兩種對(duì)象類(lèi)型可以使用Zato的圖形界面創(chuàng)建，也可以通過(guò)其它方法如enmasse或者API創(chuàng)建

2015416114311025.png (639×311)