Python使用RPC例子

目录
  • 主要内容
  • 远程过程调用RPC常用与分布式计算，对应Python库名为rpyc；
  • 上段为rpyc服务端，下段为rpyc调用端；

主要内容

所谓RPC，是远程过程调用（Remote Procedure Call）的简写，网上解释很多，简单来说，就是在当前进程调用其他进程的函数时，体验就像是调用本地写的函数一般。

本文实现的是在本地调用远端的类class对象的接口，也就是本地的client不实例化类对象，调用的是server端的类对象接口。

为了达到让调用层无须关心底层实现，拥有丝滑般的体验，就需要以下几个部分：

  • 客户端需要把类的接口提取出来，并将调用函数事件捕获存储起来；服务端需要把类的公有函数作为可远程调用的接口。
  • 客户端把调用函数的事件（调用的函数，参数）进行序列化并发送给服务端；服务端将客户端的调用事件反序列化，并执行相应的接口，将返回值发送给客户端。
  • 客户端与服务端通过某种方式（一般就是网络socket）进行通信。

远程过程调用RPC常用与分布式计算，对应Python库名为rpyc；

from multiprocessing import Pool
from rpyc import Service
from rpyc.utils.server import ThreadedServer  

class RemoteService(Service):  

    def on_connect(self, conn):
        print(conn)

    '''供客户端调用的方法前得加exposed_'''
    def exposed_search(self, data):
        print(data)
        data['result'] = 'ok'
        return data  

def main(port):
    sr = ThreadedServer(service=RemoteService, hostname='127.0.0.1', port=port, auto_register=False)
    print(f'Server IP: {(sr.host,sr.port)}')
    sr.start()  

if __name__ == '__main__':
    pool = Pool(processes=2)
    pool.apply_async(main, args=(9998,))
    pool.apply_async(main, kwds={'port':9999})
    pool.close()
    pool.join()

上段为rpyc服务端，下段为rpyc调用端；

import rpyc
import time
from multiprocessing import Pool

def search_db(query,port):
    conn = rpyc.connect('localhost',port)
    '''调用时省略exposed_'''
    result = conn.root.search(query)
    time.sleep(1)
    print(result)
    conn.close()

if __name__ == '__main__':
    pool = Pool(processes=2)
    pool.apply_async(search_db, args=({"match": {'name': 'user'}}, 9998))
    pool.apply_async(search_db, kwds={'query': {"match": {'name': 'user'}},'port':9999})
    pool.close()
    pool.join()

到此这篇关于Python使用RPC例子的文章就介绍到这了,更多相关Python使用RPC内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • 对python调用RPC接口的实例详解

    要调用RPC接口,python提供了一个框架grpc,这是google开源的 rpc相关文档: https://grpc.io/docs/tutorials/basic/python.html 需要安装的python包如下: 1.grpc安装 pip install grpcio 2.grpc的python protobuf相关的编译工具 pip install grpcio-tools 3.protobuf相关python依赖库 pip install protobuf 4.一些常见原型的生成

  • 在Python中使用gRPC的方法示例

    本文介绍了在Python中使用gRPC的方法示例,分享给大家,具体如下: 使用Protocol Buffers的跨平台RPC系统. 安装 使用 pip pip install grpcio pip install grpcio-tools googleapis-common-protos gRPC由两个部分构成,grpcio 和 gRPC 工具, 后者是编译 protocol buffer 以及提供生成代码的插件. 使用 编写protocol buffer 使用 gRPC 首先需要做的是设计 p

  • Python使用gRPC传输协议教程

    Python使用gRPC传输协议教程

    gRPC 简介: gRPC 是一款高性能.开源的 RPC 框架,产自 Google,基于 ProtoBuf 序列化协议进行开发,支持多种语言(Golang.Python.Java等),本篇只介绍 Python 的 gRPC 使用.因为 gRPC 对 HTTP/2 协议的支持使其在 Android.IOS 等客户端后端服务的开发领域具有良好的前景.gRPC 提供了一种简单的方法来定义服务,同时客户端可以充分利用 HTTP2 stream 的特性,从而有助于节省带宽.降低 TCP 的连接次数.节省C

  • Python grpc超时机制代码示例

    工作中遇到一个问题,上游服务通过grpc调用下游服务,但是由于下游服务负载太高导致上游服务的调用会随机出现超时的情况,但是有一点不太明确:超时之后,下游服务还会继续进行计算么? 于是自己写了一个damon试了一下: client: # Copyright 2015 gRPC authors. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file ex

  • python使用rpc框架gRPC的方法

    概述 gRPC 是谷歌开源的一个rpc(远程程序调用)框架,可以轻松实现跨语言,跨平台编程,其采用gRPC协议(基于HTTP2). rpc: remote procedure call, 翻译过来就是是远程程序调用.具体来说,就是客户端c1需要调用服务器s1上的某个方法(函数),得到相应的返回值并传递给c1. gRPC协议 要说gRPC协议需要先了解HTTP2, 虽然HTTP1.X 协议至今仍是主流协议,但是随着我们对性能要求越来越高,和web规模的不断扩大,HTTP2就应运而生. 在这里,我们

  • python实现一个简单RPC框架的示例

    本文需要一点Python socket基础. 回顾RPC 客户端(Client):服务调用方. 客户端存根(Client Stub):存放服务端地址信息,将客户端的请求参数数据信息打包成网络消息,再通过网络传输发送给服务端. 服务端存根(Server Stub):接收客户端发送过来的请求消息并进行解包,然后再调用本地服务进行处理. 服务端(Server):服务的真正提供者. Network Service:底层传输,可以是 TCP 或 HTTP. 实现jsonrpc 在实现前,简单理一下整体思路

  • python配置grpc环境

    gRPC 的安装: $ pip install grpcio 安装 ProtoBuf 相关的 python 依赖库: $ pip install protobuf 安装 python grpc 的 protobuf 编译工具: $ pip install grpcio-tools 测试 //源码路径 https://github.com/grpc/grpc git clone https://github.com/grpc/grpc cd grpc/examples/python/hellowo

  • Python使用RPC例子

    目录 主要内容 远程过程调用RPC常用与分布式计算,对应Python库名为rpyc: 上段为rpyc服务端,下段为rpyc调用端: 主要内容 所谓RPC,是远程过程调用(Remote Procedure Call)的简写,网上解释很多,简单来说,就是在当前进程调用其他进程的函数时,体验就像是调用本地写的函数一般. 本文实现的是在本地调用远端的类class对象的接口,也就是本地的client不实例化类对象,调用的是server端的类对象接口. 为了达到让调用层无须关心底层实现,拥有丝滑般的体验,就

  • 使用python模拟高斯分布例子

    正态分布(Normal distribution),也称"常态分布",又名高斯分布(Gaussian distribution) 正态曲线呈钟型,两头低,中间高,左右对称因其曲线呈钟形,因此人们又经常称之为钟形曲线. 若随机变量X服从一个数学期望为μ.方差为σ^2的正态分布.其概率密度函数为正态分布的期望值μ决定了其位置,其标准差σ决定了分布的幅度.当μ = 0,σ = 1时的正态分布是标准正态分布. 用python 模拟 #!/usr/bin/python # -*- coding:

  • Python爬虫小例子——爬取51job发布的工作职位

    概述 不知从何时起,Python和爬虫就如初恋一般,情不知所起,一往而深,相信很多朋友学习Python,都是从爬虫开始,其实究其原因,不外两方面:其一Python对爬虫的支持度比较好,类库众多.其二Pyhton的语法简单,入门容易.所以两者形影相随,不离不弃,本文主要以一个简单的小例子,简述Python在爬虫方面的简单应用,仅供学习分享使用,如有不足之处,还请指正. 涉及知识点 本例主要爬取51job发布的工作职位,用到的知识点如下: 开发环境及工具:主要用到Python3.7 ,IDE为PyC

  • 基于python实现rpc远程过程调用

    基于python实现rpc远程过程调用

    目录 基于python实现RPC的demo 前言 一.主要内容 二.实现步骤 1. 进程间的通信 2. 异步回调实现思路 总结 基于python实现RPC的demo 这是一个远程过程调用(RPC)的实现demo,可以实现不同的python进程之间通信和互相调用函数,简单易用,易于扩展.更多功能也可进一步完善,本文介绍了该实现的主要思路. 前言 计划手撸一个rpc甚久了,在间歇性push自己下终于完成的差不多了.写这个demo的原因,1)是为了学习与思考下这部分主体功能和实现思路,2)是调包时可以

  • Python XML RPC服务器端和客户端实例

    Python XML RPC服务器端和客户端实例

    一.远程过程调用RPC XML-RPC is a Remote Procedure Call method that uses XML passed via HTTP as a transport. With it, a client can call methods with parameters on a remote server (the server is named by a URI) and get back structured data. This module support

  • Python 时间操作例子和时间格式化参数小结

    1.取过去具体时间的方法: 复制代码 代码如下: #!/usr/bin/python import time  #取一天前的当前具体时间   time.strftime('%Y-%m-%d %T',time.localtime(time.time()-24*60*60)) #取15天前的当前具体时间   time.strftime('%Y-%m-%d %T',time.localtime(time.time()-15*24*60*60)) #取15天前当前具体时间的前2小时   time.str

  • java直接调用python脚本的例子

    java直接调用python脚本的例子

    复制代码 代码如下: import java.io.BufferedReader;import java.io.InputStreamReader; public class Main { public static void main(String[] args) {  try {   System.out.println("start");   Process pr = Runtime.getRuntime().exec("python test.py"); B

  • Python创建、删除桌面、启动组快捷方式的例子分享

    一.Python创桌面建快捷方式的2个例子 例子一: 复制代码 代码如下: import osimport pythoncomfrom win32com.shell import shell    from win32com.shell import shellcon def createDesktopLnk(filename,lnkname):    shortcut = pythoncom.CoCreateInstance(            shell.CLSID_ShellLink,

随机推荐