智能套接字实现 RPC
smart-socket实现RPC
RPC是目前被广泛应用于互联网服务的一项技术,关于它的基本介绍大家可通过百度了解一下,此处不再赘述。 正所谓读万卷书不如行万里路,原理性的文章看的再多都不如亲自实现一遍RPC,方可对其了解的更加透彻。 本文将以纯技术视角,为大家演示一下RPC的工作原理与实现方案。
正式开始之前,先罗列一下实现RPC需要运用到的技术点:
- 通信
- 序列化/反序列化
- 反射
- 动态代理
在具体实现上除了通信部分我们选用smart-socket来辅助,其余包括序列化/反序列化、反射、动态代理等部分我们将采用JDK提供的解决方案,待您掌握RPC后可再尝试结合第三方技术来重构RPC。
名词解释
- Provider
RPC服务提供者 - Consumer
RPC服务调用者
消息通信
既然RPC是跨网络通信服务,那我们先制定通信规则,该部分的内容涉及到通信、序列化/反序列化技术。
通信协议
通信协议我们采用最简单的length+data模式,编解码的实现算法如下。 作为示例我们假设readBuffer足够容纳一个完整的消息,协议中的data部分便是RPC服务序列化后的byte数组,Provider/Consumer则必须对byte数组完成反序列化后才能继续RPC服务处理。
public class RpcProtocol implements Protocol<byte[]> {
private static final int INTEGER_BYTES = Integer.SIZE / Byte.SIZE;
@Override
public byte[] decode(ByteBuffer readBuffer, AioSession<byte[]> session, boolean eof) {
int remaining = readBuffer.remaining();
if (remaining < INTEGER_BYTES) {
return null;
}
int messageSize = readBuffer.getInt(readBuffer.position());
if (messageSize > remaining) {
return null;
}
byte[] data = new byte[messageSize - INTEGER_BYTES];
readBuffer.getInt();
readBuffer.get(data);
return data;
}
@Override
public ByteBuffer encode(byte[] msg, AioSession<byte[]> session) {
ByteBuffer byteBuffer = ByteBuffer.allocate(msg.length + INTEGER_BYTES);
byteBuffer.putInt(byteBuffer.capacity());
byteBuffer.put(msg);
byteBuffer.flip();
return byteBuffer;
}
}
RPC请求消息
RPC请求消息由Consumer发送,Consumer需要在请求消息中提供足够信息以供Provider准确识别服务接口。核心要素包括:
- uuid
请求消息唯一标识,用于关联、识别响应消息。 - interfaceClass
Consumer要调用的API接口名 - method
Consumer要执行的API接口方法名 - paramClassList
Consumer调用的方法入参类型,用于区分同方法名不同入参的情况 - params
Consumer执行方法传入的参数值
public class RpcRequest implements Serializable {
/**
* 消息的唯一标识
*/
private final String uuid = UUID.randomUUID().toString();
/**
* 接口名称
*/
private String interfaceClass;
/**
* 调用方法
*/
private String method;
/**
* 参数类型字符串
*/
private String[] paramClassList;
/**
* 入参
*/
private Object[] params;
getX/setX()
}
RPC响应消息
RPC响应消息为Provider将接口执行结果响应给Consumer的载体。
- uuid
与RPC请求消息同值 - returnObject
RPC接口执行返回值 - returnType
RPC接口返回值类型 - exception
RPC执行异常信息,如果出现异常的话。
public class RpcResponse implements Serializable {
/**
* 消息的唯一标示,与对应的RpcRequest uuid值相同
*/
private String uuid;
/**
* 返回对象
*/
private Object returnObject;
/**
* 返回对象类型
*/
private String returnType;
/**
* 异常
*/
private String exception;
public RpcResponse(String uuid) {
this.uuid = uuid;
}
getX/setX()
}
通过上述内容便完成RPC通信的消息设计,至于RpcRequest、RpcResponse如何转化为通信协议要求的byte数组格式,我们采用JDK提供的序列化方式(生产环境不建议使用)。
- 序列化
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
ObjectOutput objectOutput = new ObjectOutputStream(byteArrayOutputStream);
objectOutput.writeObject(request);
aioSession.write(byteArrayOutputStream.toByteArray());
- 反序列化
ObjectInputStream objectInput = new ObjectInputStream(new ByteArrayInputStream(msg));
RpcResponse resp = (RpcResponse) objectInput.readObject();
RPC服务实现
通过上文方案我们解决了RPC的通信问题,接下来便得根据通信消息实现服务能力。
Consumer
由于RPC的Consumer端只有接口,没有具体实现,但在使用上我们又期望跟本地服务有同样的使用体验。 因此我们需要将接口实例化成对象,并使其具备跨应用服务能力,此处便运用到动态代理。 当Consumer调用RPC接口时,代理类内部发送请求消息至Provider并获取结果。
obj = (T) Proxy.newProxyInstance(getClass().getClassLoader(), new Class[]{remoteInterface},
new InvocationHandler() {
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
RpcRequest req = new RpcRequest();
req.setInterfaceClass(remoteInterface.getName());
req.setMethod(method.getName());
Class<?>[] types = method.getParameterTypes();
if (!ArrayUtils.isEmpty(types)) {
String[] paramClass = new String[types.length];
for (int i = 0; i < types.length; i++) {
paramClass[i] = types[i].getName();
}
req.setParamClassList(paramClass);
}
req.setParams(args);
RpcResponse rmiResp = sendRpcRequest(req);
if (StringUtils.isNotBlank(rmiResp.getException())) {
throw new RuntimeException(rmiResp.getException());
}
return rmiResp.getReturnObject();
}
});
Provider
Provider可将其提供的RPC服务维护在集合里,采用Map存储即可,key为暴露的接口名,value为接口的具体实现。 一旦Provider接受到RPC的请求消息,只需根据请求消息内容找到并执行对应的服务,最后将返回结果以消息的形式返回至Consumer即可。
ObjectInputStream objectInput = new ObjectInputStream(new ByteArrayInputStream(msg));
RpcRequest req = (RpcRequest) objectInput.readObject();
RpcResponse resp = new RpcResponse(req.getUuid());
try {
String[] paramClassList = req.getParamClassList();
Object[] paramObjList = req.getParams();
// 获取入参类型
Class<?>[] classArray = null;
if (paramClassList != null) {
classArray = new Class[paramClassList.length];
for (int i = 0; i < classArray.length; i++) {
Class<?> clazz = primitiveClass.get(paramClassList[i]);
if (clazz == null) {
classArray[i] = Class.forName(paramClassList[i]);
} else {
classArray[i] = clazz;
}
}
}
// 调用接口
Object impObj = impMap.get(req.getInterfaceClass());
if (impObj == null) {
throw new UnsupportedOperationException("can not find interface: " + req.getInterfaceClass());
}
Method method = impObj.getClass().getMethod(req.getMethod(), classArray);
Object obj = method.invoke(impObj, paramObjList);
resp.setReturnObject(obj);
resp.setReturnType(method.getReturnType().getName());
} catch (InvocationTargetException e) {
LOGGER.error(e.getMessage(), e);
resp.setException(e.getTargetException().getMessage());
} catch (Exception e) {
LOGGER.error(e.getMessage(), e);
resp.setException(e.getMessage());
}
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
objectOutput = new ObjectOutputStream(byteArrayOutputStream);
objectOutput.writeObject(resp);
session.write(byteArrayOutputStream.toByteArray());
测试RPC服务
服务端定义接口DemoApi
,并将其实现示例DemoApiImpl
注册至Provider中。
public class Provider {
public static void main(String[] args) throws IOException {
RpcProviderProcessor rpcProviderProcessor = new RpcProviderProcessor();
AioQuickServer<byte[]> server = new AioQuickServer<>(8888, new RpcProtocol(), rpcProviderProcessor);
server.start();
rpcProviderProcessor.publishService(DemoApi.class, new DemoApiImpl());
}
}
Consumer调用RPC接口test
、sum
获得执行结果。
public class Consumer {
public static void main(String[] args) throws InterruptedException, ExecutionException, IOException {
RpcConsumerProcessor rpcConsumerProcessor = new RpcConsumerProcessor();
AioQuickClient<byte[]> consumer = new AioQuickClient<>("localhost", 8888, new RpcProtocol(), rpcConsumerProcessor);
consumer.start();
DemoApi demoApi = rpcConsumerProcessor.getObject(DemoApi.class);
System.out.println(demoApi.test("smart-socket"));
System.out.println(demoApi.sum(1, 2));
}
}
总结
本文简要描述了RPC服务实现的关键部分,但是提供稳定可靠的RPC服务还有很多细节需要考虑,有兴趣的朋友可自行研究。 本文示例的完整代码可从smart-socket项目中获取。
上一篇: Spring AOP 详解 + 代码示例
推荐阅读
-
智能套接字实现 RPC
-
网络视频课程 8:使用套接字实现 UDP 客户端
-
反传销网8月30日发布:视频区块链里的骗子,币里的韭菜,杜子建骂人了!金融大V周召说区块链!——“一小帮骗子玩一大帮小白,被割韭菜,小白还轮流被割,割的就是你!” 什么区块链,统统是骗子 作者:周召(知乎金融领域大V,毕业于上海财经大学,目前任职上海某股权投资基金合伙人) 有人问我,区块链现在这么火,到底是不是骗局? 我的回答是: 是骗局。而且我并不是说数字货币是骗局,而是说所有搞区块链的都是骗局。 -01- 区块链是一种鸡肋技术 人类社会任何技术的发明应用,本质都是为了提高社会的生产效率。而所谓区块链技术本质不过是几种早已成熟的技术的大杂烩,冗余且十分低效,除了提高了洗钱和诈骗的效率以外,对人类社会的进步毫无贡献。 真正意义上的区块链得包含三个要素:分布式系统(包括记账和存储),无法篡改的数据结构,以及共识算法,三者互为基础和因果,就像三体世界一样。看上去挺让人不明觉厉的,而经过几年的瞎折腾,稍微懂点区块链的碰了几次壁后都已经渐渐明白区块链其实并没有什么卵用,区块链技术已经名存实亡,沦为了营销工具和传销组织的画皮。 因为符合上述定义的、以比特币为代表的原教旨区块链技术,是反效率的,从经济学角度来说,不但不是一种帕累托改进,甚至还可以说是一种帕累托倒退。 原教旨区块链技术的效率十分低下,因为要遍历所有节点,只能做非常轻量级的数据应用,一旦涉及到大量的数据传输与更新,区块链就瞎了。 一方面整条链交易速度会极慢,另一方面数据库容量极速膨胀,考虑到人手一份的存储机制,区块链其实是对存储资源和能源的一种极大的浪费。 这里还没有加上为了取得所谓的共识和挖矿消耗的巨大的能源,如果说区块链技术是屎,那么这波区块链投机浪潮可谓人类历史上最大规模的搅屎运动。 区块链也验证不了任何东西。 所谓的智能合约,即不智能,也非合约。我看有人还说,如果有了智能合约,就可以跟老板签一份放区块链上,如果明年销售业绩提升30%,就加薪10%,由于区块链不能篡改,不能抵赖,所以老板必须得执行,说得有板有眼,不懂行的愣一看,好像还真是那么回事。 但仔细一想,问题就来了。首先,在区块链上如何证明你真的达到了30%业绩提升?即便真的达到老板耍赖如何执行? 也就是说,如果区块链真这么厉害,要法院和仲裁干什么。 人类社会真正的符合成本效益原则的是代理制度。之前有人说要用区块链改造注册会计师行业,我不知道他准备怎么设计,我猜想他思路大概是这样的,首先肯定搞去中心化,让所有会计师到链上来,然后一个新人要成为注册会计师就要所有会计师同意并记录在链上。 那我就请问了,我每天上班累死累活,为什么还要花时间去验证一个跟我无关的的人的专业能力?最优做法当然是组织一个委员会,让专门的人来负责,这不就是现在注册会师协会干的事儿吗?区块链的逻辑相当于什么事情都要拿出来公投,这个绝对是扯淡的。 当然这么说都有点抬举区块链了,区块链技术本身根本没有判断是非能力,如果这么高级的人工智能,靠一个无脑分布式记账就能实现的话,我们早就进入共产主义社会了。 虽然EOS等数字货币采用了超级节点,通过再中心化的方式提高效率,有点行业协会的意思,是对区块链原教旨主义的一种修正,但是依然无法突破区块链技术最本质的局限性。有人说,私有链和联盟链是区块链技术的未来,也是扯淡,因为区块链技术没有未来。如果有,说明他是包装成区块链的伪区块链技术。 区块链所涉及的所有底层技术,不管是分布式数据库技术,加密技术,还是点对点传输技术等,基本都是早已存在没什么秘密可言的技术。 比特币系统最重要的特性是封闭性和自洽性,他验证不了任何系统自身以外产生的信息的真实性。 所谓系统自身产生的信息,就是数据库数据的变动信息,有价值的基本上有且只有交易信息。所以说比特币最初不过是中本聪一种炫技的产物,来证明自己对几种技术的掌握,你看我多牛逼,设计出了一个像三体一样的系统。因此,数字货币很有可能是区块链从始至终唯一的杀手应用。 比特币和区块链概念从诞生到今天已经快10年了,很多人说区块链技术在爆发的前夜,但这个前夜好像是不是有点过长了啊朋友,跟三体里的长夜有一拼啊。都说区块链技术像是90年代初的互联网,可是90年代初的互联网在十年发展后,已经出现了一大批伟大的公司,阿里巴巴在99年都成立了,区块链怎么除了币还是币呢? 正规的数字货币未来发展的形式无外乎几种,要么就是论坛币形式,或者类似股票的权益凭证等。问题是论坛币和股票之前,本来也都电子化了,区块链来了到底改变了什么呢? 所有想把TOKEN和应用场景结合起来的人最后都很痛苦,最后他们会发现区块链技术就是脱裤子放屁,自己辛苦搞半天,干嘛不自己作为中心关心门来收钱?最后这些人都产生了价值的虚无感,最终精神崩溃,只能发币疯狂收割韭菜,一边嘴里还说着我是个好人之类的奇怪的话。 因此,之前币圈链圈还泾渭分明,互相瞧不起,但这两年链圈逐渐坐不住了,想着是不是趁着泡沫没彻底破灭之前赶快收割一波,不然可能什么都捞不着了。 前段时间和一个名校毕业的链圈朋友瞎聊天,他说他们“致力于用区块链技术解决数字版权保护问题”,我就问他一个问题,你们如何保证你链的版权所有权声明是真实的,万一盗版者抢先一步把数据放在链上怎么办。他说他们的解决方案是连入国家数字版权保护中心的数据库进行验证…… 所以说区块链技术就是个鸡肋,研究到最后都会落入效率与真实性的黑洞,很多人一头扎进链圈后才发现,真正意义上的区块链技术,其实什么都干不了。 -02- 不是蠢就是坏的区块链媒体 空气币和区块链的造富神话,让区块链自媒体也开始迎风乱扭。一群群根本不知道区块链为何物的妖魔鬼怪纷纷进驻区块链自媒体战场,开始大放厥词胡编乱造。 任何东西,但凡只要和区块,链,分,分布式,记账,加密,验证,可追溯等等这些个关键词沾到哪怕一点点,这些所谓的区块链媒体人就会像狗闻到了屎了一样疯狂地把区块链概念往上套。 这让我想起曾经一度也是热闹非凡的物联网,我曾经去看过江苏一家号称要改变世界的“物联网”企业,过去一看是生产路由器的,我黑人问号脸,对方解释说没有路由器万物怎么互联,我觉得他说得好有道理,竟无言以对。 好,下面让我们进入奇葩共赏析时间,来看看区城链媒体经常有哪些危言耸听的奇谈怪论 区块链(分布式记账)的典型应用是*?? 正如前面所说,真正意义上的区块链分布式记账,不光包括“记”这个动作,还包括分布式存储和共识机制等。而*诞生远远早于区块链这个词的出现,勉强算是“分布式编辑”吧,就被很多区块链媒体拿来强行充当区块链技术应用的典范。 其实事实恰恰相反,*恰恰是去中心化失败的典范,现在如果没有精英和专业人士的编辑和维护,*早就没法看了。 区块链会促进社会分工?? 罗振宇好像就说过类似的话,虽然罗振宇说过很多没有逻辑的话,但这句话绝对是最没逻辑思维的。很多区块链自媒体也常常用这句话来忽悠老百姓,说分工代表效率提高社会进步,而区块链“无疑”会促进分工,他们的理由仅仅是分工和分布式记账都共用一个“分”字,就强行把他们扯到一起。 实际情况恰恰相反,区块链是逆分工的,区块链精神是号召所有人积极地参与到他不擅长也不想掺合的事情里面去。 区块链不能像上帝一样许诺他的子民死后上天国,只能给他们许诺你们是六度人脉中的第一级,我可以赚后面五级人的钱,你处于金字塔的顶端。
-
套接字通信(UDP)的 python 实现
-
套接字 - 实现简单的一对一服务器端和客户端聊天
-
windows下进程间通信的(13种方法)-摘 要 本文讨论了进程间通信与应用程序间通信的含义及相应的实现技术,并对这些技术的原理、特性等进行了深入的分析和比较。 ---- 关键词 信号 管道 消息队列 共享存储段 信号灯 远程过程调用 Socket套接字 MQSeries 1 引言 ---- 进程间通信的主要目的是实现同一计算机系统内部的相互协作的进程之间的数据共享与信息交换,由于这些进程处于同一软件和硬件环境下,利用操作系统提供的的编程接口,用户可以方便地在程序中实现这种通信;应用程序间通信的主要目的是实现不同计算机系统中的相互协作的应用程序之间的数据共享与信息交换,由于应用程序分别运行在不同计算机系统中,它们之间要通过网络之间的协议才能实现数据共享与信息交换。进程间通信和应用程序间通信及相应的实现技术有许多相同之处,也各有自己的特色。即使是同一类型的通信也有多种的实现方法,以适应不同情况的需要。 ---- 为了充分认识和掌握这两种通信及相应的实现技术,本文将就以下几个方面对这两种通信进行深入的讨论:问题的由来、解决问题的策略和方法、每种方法的工作原理和实现、每种实现方法的特点和适用的范围等。 2 进程间的通信及其实现技术 ---- 用户提交给计算机的任务最终都是通过一个个的进程来完成的。在一组并发进程中的任何两个进程之间,如果都不存在公共变量,则称该组进程为不相交的。在不相交的进程组中,每个进程都独立于其它进程,它的运行环境与顺序程序一样,而且它的运行环境也不为别的进程所改变。运行的结果是确定的,不会发生与时间相关的错误。 ---- 但是,在实际中,并发进程的各个进程之间并不是完全互相独立的,它们之间往往存在着相互制约的关系。进程之间的相互制约关系表现为两种方式: ---- (1) 间接相互制约:共享CPU ---- (2) 直接相互制约:竞争和协作 ---- 竞争——进程对共享资源的竞争。为保证进程互斥地访问共享资源,各进程必须互斥地进入各自的临界段。 ---- 协作——进程之间交换数据。为完成一个共同任务而同时运行的一组进程称为同组进程,它们之间必须交换数据,以达到协作完成任务的目的,交换数据可以通知对方可以做某事或者委托对方做某事。 ---- 共享CPU问题由操作系统的进程调度来实现,进程间的竞争和协作由进程间的通信来完成。进程间的通信一般由操作系统提供编程接口,由程序员在程序中实现。UNIX在这个方面可以说最具特色,它提供了一整套进程间的数据共享与信息交换的处理方法——进程通信机制(IPC)。因此,我们就以UNIX为例来分析进程间通信的各种实现技术。 ---- 在UNIX中,文件(File)、信号(Signal)、无名管道(Unnamed Pipes)、有名管道(FIFOs)是传统IPC功能;新的IPC功能包括消息队列(Message queues)、共享存储段(Shared memory segment)和信号灯(Semapores)。 ---- (1) 信号 ---- 信号机制是UNIX为进程中断处理而设置的。它只是一组预定义的值,因此不能用于信息交换,仅用于进程中断控制。例如在发生浮点错、非法内存访问、执行无效指令、某些按键(如ctrl-c、del等)等都会产生一个信号,操作系统就会调用有关的系统调用或用户定义的处理过程来处理。 ---- 信号处理的系统调用是signal,调用形式是: ---- signal(signalno,action) ---- 其中,signalno是规定信号编号的值,action指明当特定的信号发生时所执行的动作。 ---- (2) 无名管道和有名管道 ---- 无名管道实际上是内存中的一个临时存储区,它由系统安全控制,并且独立于创建它的进程的内存区。管道对数据采用先进先出方式管理,并严格按顺序操作,例如不能对管道进行搜索,管道中的信息只能读一次。 ---- 无名管道只能用于两个相互协作的进程之间的通信,并且访问无名管道的进程必须有共同的祖先。 ---- 系统提供了许多标准管道库函数,如: pipe——打开一个可以读写的管道; close——关闭相应的管道; read——从管道中读取字符; write——向管道中写入字符; ---- 有名管道的操作和无名管道类似,不同的地方在于使用有名管道的进程不需要具有共同的祖先,其它进程,只要知道该管道的名字,就可以访问它。管道非常适合进程之间快速交换信息。 ---- (3) 消息队列(MQ) ---- 消息队列是内存中独立于生成它的进程的一段存储区,一旦创建消息队列,任何进程,只要具有正确的的访问权限,都可以访问消息队列,消息队列非常适合于在进程间交换短信息。 ---- 消息队列的每条消息由类型编号来分类,这样接收进程可以选择读取特定的消息类型——这一点与管道不同。消息队列在创建后将一直存在,直到使用msgctl系统调用或iqcrm -q命令删除它为止。 ---- 系统提供了许多有关创建、使用和管理消息队列的系统调用,如: ---- int msgget(key,flag)——创建一个具有flag权限的MQ及其相应的结构,并返回一个唯一的正整数msqid(MQ的标识符); ---- int msgsnd(msqid,msgp,msgsz,msgtyp,flag)——向队列中发送信息; ---- int msgrcv(msqid,cmd,buf)——从队列中接收信息; ---- int msgctl(msqid,cmd,buf)——对MQ的控制操作; ---- (4) 共享存储段(SM) ---- 共享存储段是主存的一部分,它由一个或多个独立的进程共享。各进程的数据段与共享存储段相关联,对每个进程来说,共享存储段有不同的虚拟地址。系统提供的有关SM的系统调用有: ---- int shmget(key,size,flag)——创建大小为size的SM段,其相应的数据结构名为key,并返回共享内存区的标识符shmid; ---- char shmat(shmid,address,flag)——将当前进程数据段的地址赋给shmget所返回的名为shmid的SM段; ---- int shmdr(address)——从进程地址空间删除SM段; ---- int shmctl (shmid,cmd,buf)——对SM的控制操作; ---- SM的大小只受主存限制,SM段的访问及进程间的信息交换可以通过同步读写来完成。同步通常由信号灯来实现。SM非常适合进程之间大量数据的共享。 ---- (5) 信号灯 ---- 在UNIX中,信号灯是一组进程共享的数据结构,当几个进程竞争同一资源时(文件、共享内存或消息队列等),它们的操作便由信号灯来同步,以防止互相干扰。 ---- 信号灯保证了某一时刻只有一个进程访问某一临界资源,所有请求该资源的其它进程都将被挂起,一旦该资源得到释放,系统才允许其它进程访问该资源。信号灯通常配对使用,以便实现资源的加锁和解锁。 ---- 进程间通信的实现技术的特点是:操作系统提供实现机制和编程接口,由用户在程序中实现,保证进程间可以进行快速的信息交换和大量数据的共享。但是,上述方式主要适合在同一台计算机系统内部的进程之间的通信。 3 应用程序间的通信及其实现技术 ---- 同进程之间的相互制约一样,不同的应用程序之间也存在竞争和协作的关系。UNIX操作系统也提供一些可用于应用程序之间实现数据共享与信息交换的编程接口,程序员可以通过自己编程来实现。如远程过程调用和基于TCP/IP协议的套接字(Socket)编程。但是,相对普通程序员来说,它们涉及的技术比较深,编程也比较复杂,实现起来困难较大。 ---- 于是,一种新的技术应运而生——通过将有关通信的细节完全掩盖在某个独立软件内部,即底层的通讯工作和相应的维护管理工作由该软件内部来实现,用户只需要将通信任务提交给该软件去完成,而不必理会它的具体工作过程——这就是所谓的中间件技术。 ---- 我们在这里分别讨论这三种常用的应用程序间通信的实现技术——远程过程调用、会话编程技术和MQSeries消息队列技术。其中远程过程调用和会话编程属于比较低级的方式,程序员参与的程度较深,而MQSeries消息队列则属于比较高级的方式,即中间件方式,程序员参与的程度较浅。 ---- 4.1 远程过程调用(RPC)
-
实操指南:如何在Unix系统中通过域套接字实现进程间通信(IPC之九)
-
nodejs实现套接字服务功能详解