oslo RPC Client消息接口简介

class oslo_messaging.RPCClient(transporttargettimeout=Noneversion_cap=Noneserializer=Noneretry=None)

RPCClient是用于在远程RPC服务器上调用方法的类。

transport:RPCClient通过transport向RPC server发送远程调用并接收响应。

支持两种模式:

RPC calls:适用于期望有调用响应的场景,远程调用方法并等待响应

RPC casts:适用于不需要RPC server返回响应的场景

client:用于控制如何将RPC request传递到服务器。如果只有topic(exchange可选)被设置,RPC能够被任何监听该topic(以及exchange)的servers服务,多个servers按照round-robin的方式轮流被选中。在RPC Cast场景下,通过设置target的"fanout"属性为True,可以把request广播到所有监听的servers。

在构造过程中创建默认target后,target属性能够在单独的方法调用中使用prepare方法进行重配置。

方法调用由请求上下文字典,方法名称和参数字典组成。

使用类封装RPC Client的例子:

class TestClient(object):

    def __init__(self, transport):
        target = messaging.Target(topic=‘test‘, version=‘2.0‘)
        self._client = messaging.RPCClient(transport, target)

    def test(self, ctxt, arg):
        return self._client.call(ctxt, ‘test‘, arg=arg)

使用prepare方式重新设置target属性的例子:

def test(self, ctxt, arg):
    cctxt = self._client.prepare(version=‘2.5‘)
    return cctxt.call(ctxt, ‘test‘, arg=arg)

另一个例子,设置超时时间:

def test(self, ctxt, arg):
    cctxt = self._client.prepare(timeout=10)
    return cctxt.call(ctxt, ‘test‘, arg=arg)

如果连接无法完成,client会尝试重新建立连接,默认将无限期继续直到连接完成,可以设置retry次数:

client = messaging.RPCClient(transport, target, retry=None)
client.call(ctxt, ‘sync‘)
try:
    client.prepare(retry=0).cast(ctxt, ‘ping‘)
except messaging.MessageDeliveryFailure:
    LOG.error("Failed to send ping message")

call(ctxtmethod**kwargs)

call方法,触发调用并等待响应。

只允许返回单个响应值,不支持调用一个fanout模式的target。

在单一线程内能够保证多个call方法按顺序处理。

方法参数必须是原始类型或者客户端序列化器支持的类型(如果有)。 类似地,请求上下文必须是字典类型,除非客户端的序列化程序支持序列化另一个类型。

can_send_version(version=<object object>)

检查版本是否与版本上限兼容。

cast(ctxtmethod**kwargs)

触发方法并且不会为返回值阻塞。

cast() RPC请求可以广播到所有相匹配的servers。

cast会阻塞直到RPC request方法被messaging transport接受,但不确认方法是否被server调用。

cast保证方法不会在一个目的地被执行两次。

cast不保证执行顺序。

类似的,请求上下文必须是字典类型,除非客户端的序列化程序支持序列化另一个类型。

prepare(exchange=<object object>, topic=<object object>, namespace=<object object>, version=<object object>, server=<object object>, fanout=<object object>, timeout=<object object>, version_cap=<object object>, retry=<object object>)

准备方法调用上下文。

使用此方法覆盖单个方法调用的客户端属性。 例如:

def test(self, ctxt, arg):
    cctxt = self.prepare(version=‘2.5‘)
    return cctxt.call(ctxt, ‘test‘, arg=arg)

exception oslo_messaging.RemoteError(exc_type=Nonevalue=Nonetraceback=None)

表示远程端点方法引发了异常。

时间: 2024-10-22 12:44:00

oslo RPC Client消息接口简介的相关文章

Linux中的IO复用接口简介(文件监视?)

I/O复用是Linux中的I/O模型之一.所谓I/O复用,指的是进程预先告诉内核,使得内核一旦发现进程指定的一个或多个I/O条件就绪,就通知进程进行处理,从而不会在单个I/O上导致阻塞. 在Linux中,提供了select.poll.epoll三类接口来实现I/O复用. select函数接口 select中主要就是一个select函数,用于监听指定事件的发生,原型如下: 12345 #include<sys/select.h>#include<sys/time.h>int sele

Linux wext和nl80211接口简介

inux无线驱动接口简介 在分析wpa_supplicant软件linux版本下无线驱动事件和无线驱动配置代码之前,先简单介绍下linux无线驱动接口的实现技术和发展情况. Linux无线驱动接口有两种标准接口,wext(Wireless Extensions无线扩展接口)和nl80211接口. 在linux-2.6.18版本之前,linux内核代码中并没有提供无线驱动接口以及无线驱动协议栈.wext是由开发者Jean Tourrilhes (惠普实验室软件工程师)定义的一套供用户层软件访问无线

夺命雷公狗---微信开发23----客服消息接口基础和推送文本

我们这边课程里面一共用到了三个文件,分别是WeChat.class.php和common.php以及index.php 我们在写这个功能之前也要学会查手册,手册我们可以在微信开发这里找到,如下所示: 点击进去后我们将会看到客服接口,我们可以点击下进去看看里面有什么动动 这里有一个发送文本消息的,我们点击进去看下 这里很明显就看到文本消息是通过一个json数据来进行实现的,废话不多说,开工 这里我们先来写一个WeChat.php的文件,这里作用主要适用于封装一个CURL上传类的,代码如下所示: <

微信公众平台消息接口开发-封装weixin.class.php(转)

一.封装weixin.class.php 由于微信公众平台的通信使用的是特定格式的XML数据,每次接受和回复都要去做一大堆的数据处理. 我们就考虑在这个基础上做一次封装,weixin.class.php,代码如下: <?php class Weixin {     public $token = '';//token     public $debug =  false;//是否debug的状态标示,方便我们在调试的时候记录一些中间数据     public $setFlag = false;

SQLite3 C/C++ 开发接口简介

SQLite3 C/C++ 开发接口简介 1.0 总览 SQLite3是SQLite一个全新的版本,它虽然是在SQLite 2.8.13的代码基础之上开发的,但是使用了和之前的版本不兼容的数据库格式和API. SQLite3是为了满足以下的需求而开发的: 支持UTF-16编码. 用户自定义的文本排序方法. 可以对BLOBs字段建立索引. 因此为了支持这些特性我改变了数据库的格式,建立了一个与之前版本不兼容的3.0版. 至于其他的兼容性的改变,例如全新的API等等,都将在理论介绍之后向你说明,这样

微信公众平台开发教程(二) 基本原理及消息接口

微信公众平台开发教程(二) 基本原理及消息接口 一.基本原理 在开始做之前,大家可能对这个很感兴趣,但是又比较茫然.是不是很复杂?很难学啊? 其实恰恰相反,很简单.为了打消大家的顾虑,先简单介绍了微信公众平台的基本原理. 微信服务器就相当于一个转发服务器,终端(手机.Pad等)发起请求至微信服务器,微信服务器,然后将请求转发给自定义服务(这就里就是我们的具体实现). 服务处理完毕,然后挥发给微信服务器,微信服务器再将具体响应回复到终端. 通信协议为:HTTP 数据格式为:XML 具体的流程如下图

通用权限管理系统接口文档V4.2 版本之消息接口介绍

通用权限管理系统提供的消息接口可实现消息获取,消息发送,底层使用Redis对消息进行缓存,解决消息的并发请求对数据库的压力. 前端可以通过客户端轮询来获取最新消息,前端效果截图如下: 1.发送消息 2.收到消息 3.消息回复 前端效果参考代码,前端可根据自己的需要进行功能封装,实现即时消息的功能,主要是JS实现的消息轮询和发送功能, Html部分: <div style="display: none" id="ShowMessage"> <tabl

微信公众平台消息接口开发-封装weixin.class.php

原文:微信公众平台消息接口开发-封装weixin.class.php 一.封装weixin.class.php 由于微信公众平台的通信使用的是特定格式的XML数据,每次接受和回复都要去做一大堆的数据处理. 我们就考虑在这个基础上做一次封装,weixin.class.php,代码如下: <?php class Weixin {     public $token = '';//token     public $debug =  false;//是否debug的状态标示,方便我们在调试的时候记录一

夺命雷公狗---微信开发27----客服消息接口基础和推送图文消息

按照25课的套路在改下index.php即可实现,代码如下所示: <?php /** * wechat php test */ //define your token require_once "common.php"; //这里是引入curl发送函数的类 require_once 'WeChat.class.php'; define("TOKEN", "twgdh"); //这里让这个类继承了curl发送参数的类 class wechat