基于jsonrpc4j实现JSON-RPC over TCP

1.JSON-RPC说明

JSON-RPC是一个无状态且轻量级的远程过程调用(RPC)协议。
它主要定义了一些数据结构及其相关的处理规则。
它运行时可以基于tcp(socket),http等不同的消息传输方式,
即它不关心底层传输方式的细节。
它使用JSON(RFC 4627)作为数据格式。
目前版本为JSON-RPC 2.0。

2.JSON-RPC over TCP说明

JSON-RPC over TCP是一种基于TCP协议的传输方式实现JSON-RPC,
它的底层通过TCP套接字在客户端和服务器之间传输JSON格式的数据。

JSON-RPC over TCP的优势:

  • 双向通信:TCP套接字允许客户端和服务器之间进行双向通信,使得数据的传输更加灵活和高效。
  • JSON格式:使用JSON格式进行数据传输,使得数据的解析和处理更加简单和方便。
  • TCP协议:基于TCP协议的实现,保证了数据的可靠性和稳定性。
  • 适用场景:适用于各种场景,包括实时通信、远程控制、数据同步等。

3.jsonrpc4j开源库

jsonrpc4j是java编程语言实现的JSON-RPC开源工具库。
它使用Jackson库将java对象与json对象(以及与JSON-RPC相关的其他东西)进行转换。
它能提供如下多种特性:

  • Streaming server (InputStream \ OutputStream)
  • HTTP Server (HttpServletRequest \ HttpServletResponse)
  • Portlet Server (ResourceRequest \ ResourceResponse)
  • Socket Server (StreamServer)
  • Integration with the Spring Framework (RemoteExporter)
  • Streaming client
  • HTTP client
  • Dynamic client proxies
  • Annotations support
  • Custom error resolving
  • Composite services

Maven依赖:

<dependency><groupId>com.github.briandilley.jsonrpc4j</groupId><artifactId>jsonrpc4j</artifactId><version>1.6</version>
</dependency>

4.JSON-RPC over TCP Demo

下面基于jsonrpc4j开源库提供的 Socket Server (StreamServer)功能,
实现一个JSON-RPC over TCP Demo,
服务端使用Socket Server提供JSON-RPC服务,
客户端使用Socket Client访问JSON-RPC服务,
客户端和服务端之间使用TCP协议通信。

5.JSON-RPC服务端

新建Maven工程,添加pom.xml依赖:

    <dependencies><dependency><groupId>com.github.briandilley.jsonrpc4j</groupId><artifactId>jsonrpc4j</artifactId><version>1.6</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId><version>2.16.0</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId><version>2.16.0</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.16.0</version></dependency><dependency><groupId>org.apache.tomcat.embed</groupId><artifactId>tomcat-embed-core</artifactId><version>9.0.36</version></dependency><dependency><groupId>org.junit.jupiter</groupId><artifactId>junit-jupiter</artifactId><version>5.8.0</version><scope>test</scope></dependency></dependencies>

新建业务接口MathCalcService.java,
用于对外提供RPC服务:

package com.ai.json.rpc.service;public interface MathCalcService {int add(int a, int b);int subtract(int a, int b);
}

新建业务实现类MathCalcServiceImpl.java:

package com.ai.json.rpc.service.impl;import com.ai.json.rpc.service.MathCalcService;public class MathCalcServiceImpl implements MathCalcService {@Overridepublic int add(int a, int b) {return a + b;}@Overridepublic int subtract(int a, int b) {return a - b;}
}

新建服务端启动类JsonRpcStreamServer.java:

package com.ai.json.rpc;import java.net.ServerSocket;import javax.net.ServerSocketFactory;import com.ai.json.rpc.service.MathCalcService;
import com.ai.json.rpc.service.impl.MathCalcServiceImpl;
import com.googlecode.jsonrpc4j.JsonRpcServer;
import com.googlecode.jsonrpc4j.StreamServer;/*** 启动JSON RPC服务端,基于Socket对外提供服务*/
public class JsonRpcStreamServer {public static void main(String[] args) throws Exception {// 在本地8080端口进行监听ServerSocket serverSocket = ServerSocketFactory.getDefault().createServerSocket(8080);JsonRpcServer jsonRpcServer = new JsonRpcServer(new MathCalcServiceImpl(), MathCalcService.class);// 服务端处理线程池中的最大线程为8个StreamServer server = new StreamServer(jsonRpcServer, 8, serverSocket);server.start();}
}

6.JSON-RPC客户端

新建客户端测试类JsonRpcServerTest.java:

package com.ai.json.rpc;import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;import org.junit.jupiter.api.Test;import com.googlecode.jsonrpc4j.JsonRpcClient;public class JsonRpcServerTest {/*** 基于Socket的客户端调用,直接使用JsonRpcClient,对应服务端JsonRpcStreamServer*/@Testpublic void testClient2ServerBySocket() throws Throwable {// 打开socket客户端连接String serverIP = "localhost";int serverPort = 8080;Socket socket = new Socket(serverIP, serverPort);// 打开JsonRpc客户端JsonRpcClient client = new JsonRpcClient();OutputStream output = socket.getOutputStream();InputStream input = socket.getInputStream();// 调用服务端的add方法,此时不需要目的URL,只需要知道方法名Integer result1 = client.invokeAndReadResponse("add", new Object[] { 3, 5 }, Integer.class, output, input);// 输出:8System.out.println(result1);// 调用服务端的subtract方法Integer result2 = client.invokeAndReadResponse("subtract", new Object[] { 10, 5 }, Integer.class, output,input);// 输出:5System.out.println(result2);// 关闭socket.close();}}

7.运行测试

首先启动服务端,
然后运行客户端,
输出如下结果,
表示JSON RPC调用成功。

服务端输出:

16:18:26.864 [main] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.<init>(JsonRpcBasicServer.java:109)] - created server for interface interface com.ai.json.rpc.service.MathCalcService with handler class com.ai.json.rpc.service.impl.MathCalcServiceImpl
16:18:26.869 [main] DEBUG [com.googlecode.jsonrpc4j.StreamServer.start(StreamServer.java:93)] - StreamServer starting 0.0.0.0/0.0.0.0:8080
16:18:44.960 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.StreamServer$Server.run(StreamServer.java:215)] - Client connected: 127.0.0.1:7924
16:18:46.335 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.handleObject(JsonRpcBasicServer.java:420)] - Request: {"id":"1627298179","jsonrpc":"2.0","method":"add","params":[3,5]}
16:18:46.378 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.invoke(JsonRpcBasicServer.java:572)] - Invoking method: add with args [3, 5]
16:18:46.383 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.invoke(JsonRpcBasicServer.java:589)] - Invoked method: add, result 8
16:18:46.386 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.writeAndFlushValue(JsonRpcBasicServer.java:974)] - Response: {"jsonrpc":"2.0","id":"1627298179","result":8}
16:18:46.396 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.handleObject(JsonRpcBasicServer.java:420)] - Request: {"id":"994082771","jsonrpc":"2.0","method":"subtract","params":[10,5]}
16:18:46.397 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.invoke(JsonRpcBasicServer.java:572)] - Invoking method: subtract with args [10, 5]
16:18:46.397 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.invoke(JsonRpcBasicServer.java:589)] - Invoked method: subtract, result 5
16:18:46.397 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.JsonRpcBasicServer.writeAndFlushValue(JsonRpcBasicServer.java:974)] - Response: {"jsonrpc":"2.0","id":"994082771","result":5}
16:18:46.420 [pool-2-thread-1] DEBUG [com.googlecode.jsonrpc4j.StreamServer$Server.run(StreamServer.java:250)] - Client disconnected: 127.0.0.1:7924

客户端输出:

16:54:35.778 [main] DEBUG [com.googlecode.jsonrpc4j.JsonRpcClient.internalWriteRequest(JsonRpcClient.java:306)] - Request {"id":"677962822","jsonrpc":"2.0","method":"add","params":[3,5]}
16:54:35.801 [main] DEBUG [com.googlecode.jsonrpc4j.JsonRpcClient.readResponseNode(JsonRpcClient.java:313)] - JSON-RPC Response: {"jsonrpc":"2.0","id":"677962822","result":8}
8
16:54:35.806 [main] DEBUG [com.googlecode.jsonrpc4j.JsonRpcClient.internalWriteRequest(JsonRpcClient.java:306)] - Request {"id":"464162296","jsonrpc":"2.0","method":"subtract","params":[10,5]}
16:54:35.807 [main] DEBUG [com.googlecode.jsonrpc4j.JsonRpcClient.readResponseNode(JsonRpcClient.java:313)] - JSON-RPC Response: {"jsonrpc":"2.0","id":"464162296","result":5}
5

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/191057.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java研学-配置文件

一 配置文件 1 作用–解决硬编码的问题 在实际开发中,有时将变量的值直接定义在.java源文件中;如果维护人员想要修改数据,无法完成(因为没有修改权限),这种操作称之为硬编码 2 执行原理: 将经常需要改变的数据定义在指定类型的文件中,通过java代码对指定的类型的文件进行操作…

鸿蒙学习之TypeScript 语法理解笔记

1、变量及数据类型 // string&#xff1a;字符串&#xff0c;单引号或双引号 let msg : string hello wprld console.log(msg:msg)// number&#xff1a;数值、整数、浮点let num :number 21console.log(num:num)//boolean&#xff1a;布尔let finished: boolean truecons…

读书笔记:《Effective Modern C++(C++14)》

Effective Modern C&#xff08;C14&#xff09; GitHub - CnTransGroup/EffectiveModernCppChinese: 《Effective Modern C》- 完成翻译 Deducing Types 模版类型推导&#xff1a; 引用&#xff0c;const&#xff0c;volatile被忽略数组名和函数名退化为指针通用引用&#…

java学习part30callabel和线程池方式

140-多线程-线程的创建方式3、4&#xff1a;实现Callable与线程池_哔哩哔哩_bilibili 1.Callable 实现类 使用方式 返回值 2.线程池

DPDK-Hello-World示例应用程序

文章目录 前言环境安装编写hello-world程序 前言 目标: 在linux上安装DPDK的程序编写环境&#xff0c;编写和运行DPDK的hello world程序。 声明&#xff1a;我不清楚DPDK具体是个啥。DPDK的目的大概是&#xff1a;原先的网络数据需要从内核层拷贝到用户层&#xff0c;在IO越来…

检测判断IP合法性API接口

检测判断IP合法性API接口 一、检测判断IP合法性API接口二、使用步骤1、接口2、请求参数3、请求参数示例4、接口 返回示例 三、 如何获取appKey和uid1、申请appKey:2、获取appKey和uid 四、重要说明 一、检测判断IP合法性API接口 一款免费的帮助你检测判断IP合法性API接口 二、…

“于阗佛国、美食和田”——“万人游新疆”推广活动走进企业

11月23日&#xff0c;在安徽省文旅厅、安徽省援疆指挥部、和田地区文旅局的指导和支持下&#xff0c;由安徽环球文旅集团组织的“于阗佛国、美食和田”——“万人游新疆”分享会在安徽合肥市财富广场瑞众保险&#xff08;原华夏保险&#xff09;3楼黄山厅会议室举行&#xff0c…

【Android】布局优化方案

布局优化的核心问题就是要解决因布局渲染性能不佳而导致应用卡顿的问题。 绘制流程 绘制流程&#xff1a;安卓应用的绘制流程是在UI线程上执行的&#xff0c;主要包括以下几个步骤&#xff1a; 测量&#xff08;Measure&#xff09;&#xff1a;从视图树的根节点开始&#x…

【06】ES6:数组的扩展

一、扩展运算符 扩展运算符&#xff08;spread&#xff09;是三个点&#xff08;…&#xff09;。它是 rest 参数的逆运算&#xff0c;将一个数组转为用逗号分隔的参数序列。 1、基本语法 [...array] // array表示要转换的数组console.log(...[1, 2, 3]) // 1 2 3 console.l…

Python操作合并单元格

如何使用python操作Excel实现对合并单元格的一系列操作 01、准备工作&#xff08;使用镜像下载&#xff09; pip install openpyx -i https://pypi.tuna.tsinghua.edu.cn/simple 02、简单示例 简单创建一个工作簿进行示范&#xff1a; from openpyxl import Workbook from o…

波奇学C++:智能指针(二):auto_ptr, unique_ptr, shared_ptr,weak_ptr

C98到C11&#xff1a;智能指针分为auto_ptr, unique_ptr, shared_ptr&#xff0c;weak_ptr,这几种智能都是为了解决指针拷贝构造和赋值的问题 auto_ptr&#xff1a;允许拷贝&#xff0c;但只保留一个指向空间的指针。 管理权转移&#xff0c;把拷贝对象的资源管理权转移给拷贝…

vue v-permission权限指令

控制页面及按钮的显示隐藏 src/directive/permission/index.js import permission from ./permissionconst install function(Vue) {Vue.directive(permission, permission) }if (window.Vue) {window[permission] permissionVue.use(install); // eslint-disable-line }per…

vue中实现纯数字键盘

一、完整 代码展示 <template><div class"login"><div class"login-content"><img class"img" src"../../assets/image/loginPhone.png" /><el-card class"box-card"><div slot"hea…

4.11 计算文件的大小(C语言实现)

【题目描述】编写一个C程序&#xff0c;用来计算指定文件的大小。 【题目分析】计算指定文件大小的方法很多。最直观的方法是通过扫描整个文件计算出文件的字节数。但是这种方法对系统的开销很大&#xff0c;比较浪费时间。可以巧妙地利用I/O库中提供的函数来进行文件大小的判定…

Pytorch中有哪些损失函数?

Pytorch中有哪些损失函数? 一、常见的损失1. **均方误差损失&#xff08;Mean Squared Error Loss&#xff09;&#xff1a;nn.MSELoss**2. **交叉熵损失&#xff08;Cross-Entropy Loss&#xff09;&#xff1a;nn.CrossEntropyLoss**3. **二分类交叉熵损失&#xff08;Binar…

阵列信号处理---频率-波数响应和波束方向图

波束延迟求和器 阵列是由一组全向阵元组成&#xff0c;阵元的位置为 p n p_n pn​&#xff0c;如下图所示&#xff1a; 阵元分别在对应的位置对信号进行空域采样&#xff0c;这样就产生了一组信号信号为 f ( t , p ) f(t,p) f(t,p),具体表示如下&#xff1a; f ( t , p ) [ f…

C++入门篇(零) C++入门篇概述

目录 一、C概述 1. 什么是C 2. C的发展史 3. C的工作领域 4. C关键字(C98) 二、C入门篇导论 一、C概述 1. 什么是C C是基于C语言而产生的计算机程序设计语言&#xff0c;支持多重编程模式&#xff0c;包括过程化程序设计、数据抽象、面向对象程序设计、泛型程序设计和设计模式…

SQL Server 2016(创建数据库)

1、实验环境。 某公司有一台已经安装了SQL Server 2016的服务器&#xff0c;现在需要新建数据库。 2、需求描述。 创建一个名为"db_class"的数据库&#xff0c;数据文件和日志文件初始大小设置为10MB&#xff0c;启用自动增长&#xff0c;数据库文件存放路径为C:\db…

Ubuntu系统CLion安装与Ubuntu下菜单启动图标设置

Ubuntu系统CLion安装 pycharm 同理。 参考官网安装过程&#xff1a;官网安装过程 下载linux tar.gz包 # 解压 sudo tar -xzvf CLion-*.tar.gz -C /opt/ sh /opt/clion-*/bin/clion.sh其中第二个命令是启动CLion命令 clion安装完以后&#xff0c;不会在桌面或者菜单栏建立图…

大学里学编程,为什么这么难?

在大学学习计算机专业&#xff0c;为何很多同学觉得编程学得不顺心呢&#xff1f;许多同学会有这种感觉&#xff0c;在上大学里的计算机专业课程时&#xff0c;听得头都大了&#xff0c;但是真正要写代码&#xff0c;却不知道从哪里开始&#xff0c;或是觉得&#xff0c;大学里…