rabbitmq整合spring实现rpc技术调用

怼烎@ 2022-06-03 01:45 171阅读 0赞

请求端配置文件rabbitmq-context-client.xml

**<?xml version="1.0" encoding="UTF-8"?>**

<beans**xmlns**="http://www.springframework.org/schema/beans"

**xmlns:xsi**="http://www.w3.org/2001/XMLSchema-instance"

**xmlns:rabbit**="http://www.springframework.org/schema/rabbit"

**xmlns:task**="http://www.springframework.org/schema/task"

**xmlns:p**="http://www.springframework.org/schema/p"

**xsi:schemaLocation**="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/rabbit

http://www.springframework.org/schema/rabbit/spring-rabbit-1.2.xsd

http://www.springframework.org/schema/task

http://www.springframework.org/schema/task/spring-task-3.1.xsd">

**

<task:executor**id**="rmpsConnectionTaskExecutor"**pool-size**="1"/>

<rabbit:connection-factory**id**="rmpsConnectionFactory"**channel-cache-size**="10"**executor**="rmpsConnectionTaskExecutor"

**host**="localhost"**port**="5672"**username**="hjh"**password**="hjh"

**virtual-host**="hjh\_host"/>

**

<rabbit:template**id**="rmpsAmqpTemplate"**connection-factory**="rmpsConnectionFactory"

**exchange**="SLS\_RMPS\_EXCHANGE">

</rabbit:template>

**

<rabbit:admin**id**="rmpsConnectAdmin"**connection-factory**="rmpsConnectionFactory"/>

<rabbit:queue**id**="clientToServerQueue"**name**="CLIENT\_TO\_SERVER\_QUEUE"**auto-declare**="true"

**durable**="true"**declared-by**="rmpsConnectAdmin"/>

<rabbit:direct-exchange**name**="SLS\_RMPS\_EXCHANGE"

**durable**="true"**declared-by**="rmpsConnectAdmin">

<rabbit:bindings>

<rabbit:binding**queue**="clientToServerQueue"**key**="rmpsToJcKey"/>

</rabbit:bindings>

</rabbit:direct-exchange>

**

<bean**id**="container"

**class**="net.nxmax.atp.remoting.DynamicReplyMessageListenerContainer"

**p:connectionFactory-ref**="rmpsConnectionFactory"

**p:prefetchCount**="5"**p:acknowledgeMode**="NONE"**p:concurrentConsumers**="3"

**p:messageListener-ref**="rmpsAmqpTemplate"**p:rabbitAdmin-ref**="rmpsConnectAdmin">

</bean>

<bean**id**="crossDetection"**class**="com.hjh.rabbitmq.cross.CrossDetectionByMqService">

<property**name**="amqpTemplate"**ref**="rmpsAmqpTemplate"/>

</bean>

</beans>

监听容器需要自己重写spring默认的监听容器

[1][][2][][3][][4][][5][][6][][7][][8][][9][][10][][11][][12][][13][][14][][15][][16][][17][][18][][19][][20][][21][][22][][23][][24][][25][][26][][27][][28][]

**package** net.nxmax.atp.remoting;

**import** org.slf4j.**Logger**;

**import** org.slf4j.**LoggerFactory**;

**import** org.springframework.amqp.core.**Queue**;

**import** org.springframework.amqp.rabbit.core.**RabbitTemplate**;

**import** org.springframework.amqp.rabbit.listener.**SimpleMessageListenerContainer**;

public **class** **DynamicReplyMessageListenerContainer** **extends** **SimpleMessageListenerContainer**

**protected** static **final** **Logger** logger = **LoggerFactory**.getLogger(**DynamicReplyMessageListenerContainer**.**class**);

@Override

**protected** void doInitialize() **throws** **Exception**

logger.info("执行DynamicReplyMessageListenerContainer.doInitialize()");

**super**.doInitialize();

**Object** listener = getMessageListener();

**if** (listener instanceof **RabbitTemplate**) \{

*//这个队列是服务端的答复队列，*

**Queue** queue1 = **new** **Queue**("JC\_TO\_RMPS\_QUEUE\_1");

**Queue** queue2 = **new** **Queue**("JC\_TO\_RMPS\_QUEUE\_2");

setQueues(queue1,queue2);

客户端请求实现类

**package** com.hjh.rabbitmq.cross;

**import** java.util.concurrent.Semaphore;

**import** org.springframework.amqp.core.Message;

**import** org.springframework.amqp.core.MessageProperties;

**import** org.springframework.amqp.rabbit.core.RabbitTemplate;

*/\*\**

*\* 交叉检测业务服务类，通过mq的方式请求*

*\* @author jianhua.huang*

*\* \*/*

*//@Service("crossDetectionByMq")*

**public** class CrossDetectionByMqService

**private** RabbitTemplate amqpTemplate;

*//信号量，用来控制并发线程的最大数量*

**private** Semaphore sempahore = **new** Semaphore(6);

**public** RabbitTemplate getAmqpTemplate()

**return** amqpTemplate;

**public** **void** setAmqpTemplate(RabbitTemplate amqpTemplate)

**this**.amqpTemplate = amqpTemplate;

*/\*\**

*\* 交叉检测方法入口*

*\* @author jianhua.huang*

*\* \*/*

**public** **void** doCrossDetection(**String** msgExt, **String** routingKey)

*//通过mq远程请求交叉检测数据*

MessageProperties msgProp = **new** MessageProperties();

msgProp.setContentType("text");

**String** str = "凹凸曼,凹凸曼 | " \+ msgExt + "," \+ routingKey;

Message msg = **new** Message(str.getBytes(),msgProp);

amqpTemplate.setReplyTimeout(11000);

**Object** response = **null**;

**long** start = System.currentTimeMillis();

**try**

sempahore.acquire();

System.out.println("发送出去的消息为 ： \{" \+ str \+ "\}");

amqpTemplate.setReplyAddress(routingKey);

response = amqpTemplate.convertSendAndReceive("rmpsToJcKey", msg);

System.out.println("类型 ： " \+ response.getClass().getSimpleName());

**catch** (InterruptedException e)

e.printStackTrace();

**finally**

System.out.println(msgExt + "释放一个许可");

sempahore.release();

**long** end = System.currentTimeMillis();

System.out.println("response 为： \{" \+ response + "\},耗时 = " \+ (end - start));

客户端main启动实现，主要是测试并发

[1][][2][][3][][4][][5][][6][][7][][8][][9][][10][][11][][12][][13][][14][][15][][16][][17][][18][][19][][20][][21][][22][][23][][24][][25][][26][][27][][28][][29][][30][][31][][32][][33][][34][][35][][36][][37][][38][][39][][40][][41][][42][][43][][44][][45][][46][][47][][48][][49][][50][][51][][52][][53][][54][][55][][56][][57][][58][][59][][60][][61][][62][][63][][64][][65][][66][][67][][68][][69][][70][][71][][72][][73][][74][][75][][76][][77][][78][][79][][80][][81][][82][][83][][84][][85][][86][][87][][88][][89][][90][][91][][92][][93][][94][][95][][96][][97][][98][][99][][100][][101][][102][][103][][104][][105][][106][][107][][108][][109][]

**package** net.nxmax.atp.startup;

**import** java.util.concurrent.CountDownLatch;

**import** java.util.concurrent.ExecutorService;

**import** java.util.concurrent.Executors;

**import** org.springframework.context.ApplicationContext;

**import** org.springframework.context.support.ClassPathXmlApplicationContext;

**import** com.hjh.rabbitmq.cross.CrossDetectionByMqService;

/\*\*

\* 非客户端启动类

\* @author jianhua.huang

\* \*/

**public** **class** **SimpleClientStartup** **implements** **Runnable**

**private** String routeKey;

**private** CountDownLatch countDown;

**private** CrossDetectionByMqService cross;

**public** **SimpleClientStartup**(String routeKey, CountDownLatch countDown, CrossDetectionByMqService cross)

**this**.routeKey = routeKey;

**this**.countDown = countDown;

**this**.cross = cross;

**public** **static** **void** **main**(String\[\] args)

ApplicationContext ctx = **new** ClassPathXmlApplicationContext("rpc/fixq/rabbitmq-context-client.xml");

CrossDetectionByMqService cross = ctx.getBean("crossDetection",CrossDetectionByMqService.class);

cross.doCrossDetection(Thread.currentThread().getName(), "JC\_TO\_RMPS\_KEY\_1");

*// ExecutorService service = Executors.newCachedThreadPool();*

*// final CountDownLatch countDown = new CountDownLatch(10);*

*//*

*// String\[\] keys = \{"JC\_TO\_RMPS\_KEY\_1","JC\_TO\_RMPS\_KEY\_2"\};*

*//*

*// for(int i=0;i<10;i++)*

*// \{*

*// int idx = i % 2;*

*// String routeKey = keys\[idx\];*

*// service.execute(new SimpleClientStartup(routeKey, countDown, cross));*

*// countDown.countDown();*

*// \}*

*// service.shutdown();*

@Override

**public** **void** **run**()

**try**

countDown.await();

cross.doCrossDetection(Thread.currentThread().getName(), routeKey);

\} **catch** (Exception e)

e.printStackTrace();

**public** **void** **testCountDown**()

ExecutorService service = Executors.newCachedThreadPool();

**final** CountDownLatch cdOrder = **new** CountDownLatch(1);

**final** CountDownLatch cdAnswer = **new** CountDownLatch(3);

**for**(**int** i=0;i<3;i++)

Runnable runnable = **new** Runnable()

**public** **void** **run**()

**try**

System.out.println("线程" \+ Thread.currentThread().getName() + "正准备接受命令");

cdOrder.await();

System.out.println("线程" \+ Thread.currentThread().getName() + "已接受命令");

*// Thread.sleep((long)(Math.random()\*10000));*

cdAnswer.countDown();

System.out.println("线程" \+ Thread.currentThread().getName() + "回应命令处理结果");

\} **catch** (Exception e)

e.printStackTrace();

\};

service.execute(runnable);

**try**

Thread.sleep((**long**)(Math.random()\*10000));

System.out.println("线程" \+ Thread.currentThread().getName() + "即将发布命令");

cdOrder.countDown();

System.out.println("线程" \+ Thread.currentThread().getName() + "已发送命令，正在等待结果");

cdAnswer.await();

System.out.println("线程" \+ Thread.currentThread().getName() + "已收到所有响应结果");

\} **catch** (Exception e)

e.printStackTrace();

service.shutdown();

服务端配置文件applicationContext.xml

[1][][2][][3][][4][][5][][6][][7][][8][][9][][10][][11][][12][][13][][14][][15][][16][][17][][18][][19][][20][][21][][22][][23][][24][][25][][26][][27][][28][][29][]

**<?xml version="1.0" encoding="UTF-8"?>**

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

xmlns:lang="http://www.springframework.org/schema/lang" xmlns:rabbit="http://www.springframework.org/schema/rabbit"

xmlns:util="http://www.springframework.org/schema/util"

xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd

http://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.0.xsd

http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.3.xsd

http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd">

<rabbit:connection-factory id="rabbitConnectionFactory"

host="localhost" cache-mode="CHANNEL" username="hjh" password="hjh" virtual-host="hjh\_host"/>

<rabbit:template id="amqpTemplateInternetProxy" exchange="SLS\_RMPS\_EXCHANGE"

connection-factory="rabbitConnectionFactory">

</rabbit:template>

<rabbit:admin id="rmpsConnectAdmin" connection-factory="rabbitConnectionFactory" />

<rabbit:listener-container acknowledge="none"

concurrency="3" prefetch="10">

<rabbit:listener ref="service" queue-names="CLIENT\_TO\_SERVER\_QUEUE" />

</rabbit:listener-container>

<bean id="service"

class="com.hjh.rabbitmq.cross.CrossDetectionConsumer">

</bean>

</beans>

服务端CrossDetectionConsumer类型实现

**package** com.hjh.rabbitmq.cross;

**import** org.springframework.amqp.core.Message;

**import** org.springframework.amqp.core.MessageListener;

**import** org.springframework.amqp.core.MessageProperties;

**import** org.springframework.amqp.rabbit.core.RabbitTemplate;

**import** org.springframework.stereotype.Service;

@Service

**public** **class** **CrossDetectionConsumer** **implements** **MessageListener**

**private** RabbitTemplate amqpTemplate;

**public** **void** **onMessage**(Message message)

String msg = **new** String(message.getBody());

String json = "模拟交叉检测平台的响应信息, 响应线程名称为【 " \+ msg.substring(msg.indexOf("|") + 1) + "】rpc 请求！";

MessageProperties msgProp = message.getMessageProperties();

String replyTo = msgProp.getReplyTo();

System.out.println("replyTo = " \+ replyTo);

System.out.println("当前处理线程名称 : " \+ Thread.currentThread().getName());

Message responseMsg = **new** Message(json.getBytes(),message.getMessageProperties());

*//"jcToRmpsKey"*

**try**

Thread.sleep(5000);

\} **catch** (Exception e)

*// TODO: handle exception*

amqpTemplate.send(replyTo, responseMsg);

**public** RabbitTemplate **getAmqpTemplate**()

**return** amqpTemplate;

**public** **void** **setAmqpTemplate**(RabbitTemplate amqpTemplate)

**this**.amqpTemplate = amqpTemplate;

服务端main启动类

**package** net.nxmax.atp.startup;

**import** java.io.**BufferedReader**;

**import** java.io.InputStreamReader;

**import** org.slf4j.Logger;

**import** org.slf4j.LoggerFactory;

**import** org.springframework.amqp.core.AmqpTemplate;

**import** org.springframework.context.support.ClassPathXmlApplicationContext;

**public** class ServerStartup \{

*/\*\* Logger \*/*

**private** **static** **final** Logger log = LoggerFactory

.getLogger(ServerStartup.class);

**public** **static** **void** main(**String**\[\] args) **throws** Exception \{

**new** ServerStartup().go();

**private** **void** go() **throws** Exception \{

log.info("Create ApplicationContext");

ClassPathXmlApplicationContext ctx = **new** ClassPathXmlApplicationContext("rpc/fixq/applicationContext.xml");

AmqpTemplate amqpTemplate = ctx.getBean("amqpTemplateInternetProxy",AmqpTemplate.class);

*// amqpTemplate.convertAndSend("", "");*

log.info("Create ApplicationContext Finish.");

**BufferedReader** r = **new** **BufferedReader**(**new** InputStreamReader(System.in));

**while** (!r.readLine().equalsIgnoreCase("exit")) \{

log.info("Exit now");

ctx.destroy();

注意：

由于用spring整合rabbitmq来实现rpc调用技术，在客户端(即request端)访问远程服务器的时候，其本质就是用jdk的

阻塞队列做的线程同步，因此并不限于服务器到底是使用异步的rabbitmq还是同步的rpc机制，这个总结是基于作者阅读

源码发现的。

总结

[1][][2][][3][][4][]

总之一句话，rabbitmq本质上是不存在rpc同步挑用这一说，只是**spring**在做代码封装的时候就考虑到了这个功能，所以在代码层面做出了支持。对此本人封装过一套rpc的工程代码，地址是 ： [https://gitee.com/hjh7516/hjh-rpc][https_gitee.com_hjh7516_hjh-rpc]。

对此项技术有疑问的童鞋，可以发送邮件至1807325935@qq.com中一起探讨。

[1]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L1
[2]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L2
[3]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L3
[4]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L4
[5]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L5
[6]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L6
[7]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L7
[8]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L8
[9]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L9
[10]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L10
[11]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L11
[12]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L12
[13]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L13
[14]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L14
[15]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L15
[16]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L16
[17]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L17
[18]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L18
[19]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L19
[20]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L20
[21]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L21
[22]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L22
[23]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L23
[24]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L24
[25]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L25
[26]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L26
[27]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L27
[28]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L28
[29]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L29
[30]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L30
[31]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L31
[32]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L32
[33]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L33
[34]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L34
[35]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L35
[36]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L36
[37]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L37
[38]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L38
[39]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L39
[40]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L40
[41]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L41
[42]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L42
[43]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L43
[44]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L44
[45]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L45
[46]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L46
[47]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L47
[48]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L48
[49]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L49
[50]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L50
[51]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L51
[52]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L52
[53]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L53
[54]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L54
[55]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L55
[56]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L56
[57]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L57
[58]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L58
[59]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L59
[60]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L60
[61]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L61
[62]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L62
[63]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L63
[64]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L64
[65]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L65
[66]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L66
[67]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L67
[68]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L68
[69]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L69
[70]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L70
[71]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L71
[72]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L72
[73]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L73
[74]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L74
[75]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L75
[76]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L76
[77]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L77
[78]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L78
[79]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L79
[80]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L80
[81]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L81
[82]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L82
[83]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L83
[84]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L84
[85]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L85
[86]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L86
[87]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L87
[88]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L88
[89]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L89
[90]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L90
[91]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L91
[92]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L92
[93]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L93
[94]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L94
[95]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L95
[96]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L96
[97]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L97
[98]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L98
[99]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L99
[100]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L100
[101]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L101
[102]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L102
[103]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L103
[104]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L104
[105]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L105
[106]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L106
[107]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L107
[108]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L108
[109]: https://gitee.com/hjh7516/codes/ex68iwavg74fjc1pr5ym093#L109
[https_gitee.com_hjh7516_hjh-rpc]: https://gitee.com/hjh7516/hjh-rpc