Java-代码段-http接口调用自身服务中的其他http接口(mock)-并建立socket连接发送和接收报文实例

最新版本更新
https://code.jiangjiesheng.cn/article/367?from=csdn

推荐 《高并发 & 微服务 & 性能调优实战案例100讲 源码下载》

1. controller入口

    @ApiOperation("模拟平台端+现场机socket交互过程,需要Authorization")@PostMapping(path = "/testSocketBusiness")public ResponseBean<HashMap<Object, Object>> testSocketBusiness(@RequestBody SocketTestClient.SocketAllParams socketAllParams) {// 建立socket连接  "\n")HashMap<Object, Object> res = socketTestClient.doTestAll(socketAllParams.getFirstUrlRequest(), socketAllParams.getSocketMsgList(), socketAllParams.getAutoUseNowDataTime());return new ResponseBean<>(200, "请求结束", res);}

1.1 接口入参示例及说明

{"firstUrlRequestxxxxx": {"url": "/your http api/remoteControl","method": "PUT","urlParams": {"monitorId": 3319,"cn": "3020","polId": "md0501","infoId": "i42002"}},"socketMsgList": ["ST=32;CN=3020;PW=123456;MN=887799;Flag=5;CP=&&DataTime=20250529105000;PolId=md0501;DT=201;VaseNo=4;i33022-Info=0;i33028-Info=1&&"],"autoUseNowDataTime": true,"【示例非必要不改动】反控入参示例(前不要长度、不要QN,后不要结尾,DataTime是否自动更新取决于autoUseNowDataTime)": {"firstUrlRequest": {"url": "/your http api/remoteControl","method": "PUT","urlParams": {"monitorId": 3319,"cn": "3020","polId": "md0501","infoId": "i42002"}},"socketMsgList": ["ST=91;CN=9011;PW=123456;MN=7899871;Flag=4;CP=&&QnRtn=1&&","ST=32;CN=3020;PW=123456;MN=7899871;Flag=4;CP=&&DataTime=20250528111758;PolId=md0501;i42002-Info=2&&","ST=91;CN=9012;PW=123456;MN=7899871;Flag=4;CP=&&ExeRtn=1&&"],"autoUseNowDataTime": true},"【示例非必要不改动】监测数据入参示例(前不要长度、不要QN,后不要结尾,DataTime是否自动更新取决于autoUseNowDataTime)": {"socketMsgList": ["ST=32;CN=2011;PW=123456;MN=7899871;Flag=5;CP=&&DataTime=20250527105200;w01018-Rtd=8.8,w00000-Flag=N;w01018-Rtd=444.7,w01018-SampleTime=20250527105100,w01018-Flag=D&&"],"autoUseNowDataTime": false},"一次采集日志:": ["tail -200f /home/logs/yourProject/collect/connect.log","tail -200f /home/logs/yourProject/collect/receive.log [重点]","tail -200f /home/logs/yourProject/collect/send.log","tail -200f /home/logs/yourProject/debug.log [重点]","tail -200f /home/logs/yourProject/error.log"]
}

1.2 接口出参示例

{"code": 200,"msg": "请求结束","data": {"请求结束,当期是监测数据上传模式,返回qn列表:": ["20250529132932726"]},"timestamp": "2025-05-29 13:29:36","traceId": "cb9557eaed1543aa8749bf2a545816ef"
}

2. mock test方式调用自身controller下的http接口并建立socket连接发送和接收报文实例

SocketTestClient.java

package cn.jiangjiesheng.code.service.common;import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;
import cn.jiangjiesheng.code.core.utils.ControllerInvoker;
import cn.jiangjiesheng.code.core.utils.HttpServletUtil;
import cn.jiangjiesheng.code.core.utils.StringUtils;
import cn.jiangjiesheng.code.exception.GnException;
import com.google.api.client.util.Lists;
import com.google.common.collect.Maps;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;import java.io.*;
import java.net.Socket;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;@Component
@Slf4j
public class SocketTestClient {// 配置参数:socket服务器IP/端口@Value("${ecp-collector.url}")private String socketIP;private static final int SOCKET_PORT = 16010;// 复用socketprivate static volatile Socket socket;private static final Object lock = new Object();// 建立连接使用,核心是PW=123456;MN=7899871private static final String BUILD_MN_CONNECT_FIRST_TIME = "QN=20250523094003516;ST=32;CN=2011;PW=%s;MN=%s;Flag=5;CP=&&DataTime=20250525093100;w00000-Rtd=0.00;&&4540"; // 固定内容// 发送间隔(毫秒)private static final long SEND_INTERVAL = 500;@Autowiredprivate ControllerInvoker controllerInvoker;/*** 模拟云平台和现场机交互的接口* (整个交互的多条报文在一个接口入参中写完,就不用通过socket工具来测试了,* 一次采集一套流程好像还有10秒内的限制,通过接口调用就没这些问题了。)** @param urlObj             模拟第一次业务触发* @param socketMsgList      其他交互报文* @param autoUseNowDataTime 是否自动更新DataTime,默认是* @return 返回qn*/public HashMap<Object, Object> doTestAll(FirstUrlRequest urlObj, List<String> socketMsgList, Boolean autoUseNowDataTime) {//反控的qnString qn = null;boolean isReverseControlMode = false;//记录下qn,返回便于查验List<String> qnList = Lists.newArrayList();try {//单例模式复用socketconnectToServer();if (CollectionUtils.isNotEmpty(socketMsgList)) {// 获取输出流(用于发送数据)OutputStream out = socket.getOutputStream();// 字符集String CHARSET = "UTF-8";BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out, CHARSET));//触发第1个接口请求if (urlObj != null && StringUtils.isNotBlank(urlObj.getUrl())) {//发送建立连接使用String msgOne = socketMsgList.get(0);// 正则匹配 PW 和 MN 的值String pw = extractValue(msgOne, "PW=([^;]+);");String mn = extractValue(msgOne, "MN=([^;]+);");log.info("doTestAll,PW = {}", mn);log.info("doTestAll,MN = {}", mn);sendMessage(writer, handleFinalMsg(String.format(BUILD_MN_CONNECT_FIRST_TIME, pw, mn)));//还要有首选String authorization = getRequest().getHeader("Authorization");if (StringUtils.isBlank(authorization)) {throw new GnException("请添加Authorization头");}String result = null;try {try {//这里要等待建立好mn连接,必须,否则会报"链接不可用"Thread.sleep(SEND_INTERVAL);} catch (InterruptedException e) {Thread.currentThread().interrupt();throw new GnException("发送线程被中断");}// 直接post get 方式调用会阻塞//  result = HttpConnectionsUtils.requestWithBody(urlObj.getUrl(), urlObj.getMethod(), null, JSONUtil.toJsonStr(urlObj.getUrlParams()), authorization);result = controllerInvoker.invokeController(urlObj.getUrl(), urlObj.getMethod(), JSONUtil.toJsonStr(urlObj.getUrlParams()), authorization);} catch (Exception e) {throw new GnException("当前反控接口调用失败:" + e.getMessage());}qn = JSONUtil.parseObj(result).getStr("data", "");if (StringUtils.isBlank(qn)) {throw new GnException("当前反控接口调用失败");}}//替换qn 和 DataTimeString datetime = null;if (autoUseNowDataTime == null) {autoUseNowDataTime = true;}if (autoUseNowDataTime) {datetime = DateUtil.format(new Date(), "yyyyMMddHHmmss");}//是否是反控模式isReverseControlMode = qn != null;//执行其他报文请求for (String msg : socketMsgList) {if (isReverseControlMode) {addQnList(qnList, qn);} else {//监测数据上传,这里重新生成qnqn = DateUtil.format(new Date(), "yyyyMMddHHmmssSSS");addQnList(qnList, qn);}if (msg.startsWith("QN=")) {msg = msg.replaceFirst("QN=[^;]+;", String.format("QN=%s;", qn));} else {msg = String.format("QN=%s;", qn) + msg;}if (datetime != null && msg.contains("DataTime=")) {msg = msg.replaceFirst("DataTime=[^;]+;", String.format("DataTime=%s;", datetime));}msg = handleFinalMsg(msg);try {Thread.sleep(SEND_INTERVAL);} catch (InterruptedException e) {Thread.currentThread().interrupt();log.info("发送线程被中断");break;}sendMessage(writer, msg);}// writer.close(); socket也会关闭}HashMap<Object, Object> qnMap = Maps.newHashMap();String key = String.format("请求结束,%s,返回qn列表:", isReverseControlMode ? "当前是反控模式(1个qn)" : "当期是监测数据上传模式");qnMap.put(key, qnList);return qnMap;} catch (IOException e) {log.info("连接或通信异常: " + e.getMessage());throw new GnException("连接或通信异常: " + e.getMessage());} catch (Exception e) {throw new GnException("当前反控接口调用失败:" + e.getMessage());} finally {//disconnect();}}private static void addQnList(List<String> qnList, String qn) {if (!qnList.contains(qn)) {qnList.add(qn);}}/*** 处理成最终的报文格式** @param msg* @return*/private static String handleFinalMsg(String msg) {//判断是否需要组装成完整的报文if (msg.startsWith("QN")) {// 找到最后一个 "&&" 的位置int index = msg.lastIndexOf("&&");if (index > 0 && !msg.endsWith("&&")) {//先截断msg = msg.substring(0, index + 2); // 保留 "&&}int length = msg.length();String msgStart = String.format("##%04d", length);msg = msgStart + msg;}//这个应该紧跟上面的逻辑,拼接的内容好像不重要if (msg.endsWith("&&")) {msg += "4540";}return msg;}/*** 获取当前请求的request对象** @author xuyuxiang* @date 2020/3/30 15:10*/public static HttpServletRequest getRequest() {ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();if (requestAttributes == null) {throw new GnException("请求的参数异常");} else {return requestAttributes.getRequest();}}// 提取方法private static String extractValue(String input, String regex) {Pattern pattern = Pattern.compile(regex);Matcher matcher = pattern.matcher(input);if (matcher.find()) {return matcher.group(1);}return null;}// 封装发送方法:添加 \r\n 并刷新private void sendMessage(BufferedWriter writer, String message) {try {// 添加回车换行 ,应该只要 \nwriter.write(message + "\r\n");writer.flush();log.info("doTestAll,已发送报文 {}", message);} catch (IOException e) {log.info("doTestAll,发送报文失败 {}", message);}}// 启动一个线程接收服务器响应(可选)private void startServerResponseThread(Socket socket) {new Thread(() -> {try (InputStream in = socket.getInputStream();BufferedReader reader = new BufferedReader(new InputStreamReader(in))) {String responseLine;while ((responseLine = reader.readLine()) != null) {log.info(" 收到来自服务器的报文: " + responseLine);}} catch (IOException e) {log.info(" 接收服务器报文失败: " + e.getMessage());}}).start();}/*** 单例模式复用socket*/public void connectToServer() {if (socket == null || socket.isClosed()) {//|| socket.isConnected()只表示这个 Socket 对象是否曾经成功连接过一次。synchronized (lock) {if (socket == null || socket.isClosed()) {//|| socket.isConnected()只表示这个 Socket 对象是否曾经成功连接过一次。try {socket = new Socket(socketIP, SOCKET_PORT);// 可以在这里配置 socket 参数,如设置超时时间log.info("成功连接到socket服务器:{}:{}", socketIP, SOCKET_PORT);SocketMessageReceiver receiver = new SocketMessageReceiver(socket, new MessageHandler() {@Overridepublic void onMessageReceived(String message) {log.info("收到socket回复消息:{}", message);}@Overridepublic void onConnectionClosed() {log.info("socket断开连接");}@Overridepublic void onError(Exception e) {log.info("socket连接发生错误", e);}});receiver.start();} catch (IOException e) {throw new GnException("socket连接异常:" + e.getMessage());}} else {log.info("socket已连接:{}:{}", socketIP, SOCKET_PORT);}}} else {log.info("socket已连接:{}:{}", socketIP, SOCKET_PORT);}}public void disconnect() {try {if (socket != null && !socket.isClosed()) {socket.close();socket = null;}} catch (IOException e) {throw new GnException("socket关闭异常:" + e.getMessage());}}/*** 模拟第一次业务触发*/@Datapublic static class FirstUrlRequest {private String url;private String method;private Object urlParams;}@Datapublic static class SocketAllParams {//模拟第一次业务触发private FirstUrlRequest firstUrlRequest;//其他交互报文private List<String> socketMsgList;//是否自动更新DataTime,默认是private Boolean autoUseNowDataTime;}interface MessageHandler {void onMessageReceived(String message);void onConnectionClosed();void onError(Exception e);}static class SocketMessageReceiver {private final Socket socket;private final MessageHandler handler;private volatile boolean running = true;public SocketMessageReceiver(Socket socket, MessageHandler handler) {this.socket = socket;this.handler = handler;}public void start() {new Thread(this::runLoop).start();}public void stop() {running = false;try {if (!socket.isClosed()) {socket.close();}} catch (IOException e) {handler.onError(e);}}private void runLoop() {try (InputStream in = socket.getInputStream();BufferedReader reader = new BufferedReader(new InputStreamReader(in))) {String line;while (running && (line = reader.readLine()) != null) {handler.onMessageReceived(line);}handler.onConnectionClosed();} catch (IOException e) {handler.onError(e);}}}
}

3. ControllerInvoker mock调用http接口代码

ControllerInvoker.java

package cn.jiangjiesheng.code.core.utils;import cn.jiangjiesheng.code.exception.GnException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.http.MediaType;
import org.springframework.mock.web.MockHttpServletResponse;
import org.springframework.stereotype.Service;
import org.springframework.web.servlet.HandlerAdapter;
import org.springframework.web.servlet.HandlerExecutionChain;
import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping;
import org.springframework.mock.web.MockHttpServletRequest;import java.nio.charset.StandardCharsets;/*** http调用Controller http代码接口* 依赖* <dependency>*  <groupId>org.springframework.boot</groupId>*   <artifactId>spring-boot-starter-test</artifactId>*  <!--  <version>2.0.6.RELEASE</version>-->* </dependency>*/
@Service
public class ControllerInvoker {@Autowiredprivate RequestMappingHandlerMapping handlerMapping;@Autowired//有3个@Qualifier("requestMappingHandlerAdapter")private HandlerAdapter handlerAdapter;/*** http调用Controller http代码接口,http不能直接调用自身服务的http接口,会阻塞* @param uri 不要server.servlet.context-path,示例:/your http api/remoteControl* @param method* @param jsonBody* @param authorization* @return* @throws Exception*/public String invokeController(String uri, String method,  String jsonBody, String authorization) throws Exception {MockHttpServletRequest request = new MockHttpServletRequest();request.setRequestURI(uri);request.setMethod(method.toUpperCase());request.addHeader("Authorization", authorization);request.setContentType(MediaType.APPLICATION_JSON_VALUE);request.setContent(jsonBody.getBytes(StandardCharsets.UTF_8));HandlerExecutionChain chain = handlerMapping.getHandler(request);if (chain == null) {throw new GnException("没找到对应url: " + uri);}// 执行 Controller 方法MockHttpServletResponse response = new MockHttpServletResponse();handlerAdapter.handle(request, response, chain.getHandler());return new String(response.getContentAsByteArray(), StandardCharsets.UTF_8);}
}

最新版本更新
https://code.jiangjiesheng.cn/article/367?from=csdn

推荐 《高并发 & 微服务 & 性能调优实战案例100讲 源码下载》

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

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

相关文章

基于递归思想的系统架构图自动化生成实践

文章目录 一、核心思想解析二、关键技术实现1. 动态布局算法2. 样式规范集成3. MCP服务封装三、典型应用场景四、最佳实践建议五、扩展方向一、核心思想解析 本系统通过递归算法实现了Markdown层级结构到PPTX架构图的自动转换,其核心设计思想包含两个维度: 数据结构递归:将…

Python包管理器 uv替代conda?

有人问&#xff1a;python的包管理器uv可以替代conda吗? 搞数据和算法的把conda当宝贝&#xff0c;其他的场景能替代。 Python的包管理器有很多&#xff0c;pip是原配&#xff0c;uv是后起之秀&#xff0c;conda则主打数据科学。 uv替代pip似乎只是时间问题了&#xff0c;它…

使用pnpm、vite搭建Phaserjs的开发环境

首先&#xff0c;确保你已经安装了 Node.js 和 npm。然后按照以下步骤操作&#xff1a; 一、使用pnpm初始化一个新的 Vite 项目 pnpm create vite 输入名字 选择模板&#xff0c;这里我选择Vanilla,也可以选择其他的比如vue 选择语言 项目新建完成 二、安装相关依赖 进入项…

JS逆向案例—喜马拉雅xm-sign详情页爬取

JS逆向案例——喜马拉雅xm-sign详情页爬取 声明网站流程分析总结 声明 本文章中所有内容仅供学习交流&#xff0c;抓包内容、敏感网址、数据接口均已做脱敏处理&#xff0c;严禁用于商业用途和非法用途&#xff0c;否则由此产生的一切后果均与作者无关&#xff0c;若有侵权&am…

姜老师的MBTI课程:MBTI是可以转变的

我们先来看内向和外向这条轴&#xff0c;I和E内向和外向受先天遗传因素的影响还是比较大的&#xff0c;因为它事关到了你的硬件&#xff0c;也就是大脑的模型。但是我们在大五人格的排雷避坑和这套课程里面都强调了一个观点&#xff0c;内向和外向各有优势&#xff0c;也各有不…

进程同步:生产者-消费者 题目

正确答案&#xff1a; 问题类型&#xff1a; 经典生产者 - 消费者问题 同时涉及同步和互斥。 同步&#xff1a;生产者与消费者通过信号量协调生产 / 消费节奏&#xff08;如缓冲区满时生产者等待&#xff0c;空时消费者等待&#xff09;。互斥&#xff1a;对共享缓冲区的访问需…

吴恩达MCP课程(1):chat_bot

原课程代码是用Anthropic写的&#xff0c;下面代码是用OpenAI改写的&#xff0c;模型则用阿里巴巴的模型做测试 .env 文件为&#xff1a; OPENAI_API_KEYsk-xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx OPENAI_API_BASEhttps://dashscope.aliyuncs.com/compatible-mode…

Netty 实战篇:手写一个轻量级 RPC 框架原型

本文将基于前文实现的编解码与心跳机制&#xff0c;构建一个简单的 RPC 框架&#xff0c;包括请求封装、响应解析、动态代理调用。为打造微服务通信基础打下基础。 一、什么是 RPC&#xff1f; RPC&#xff08;Remote Procedure Call&#xff0c;远程过程调用&#xff09;允许…

边缘计算新基建:iVX 轻量生成模块的 ARM 架构突围

一、引言 随着工业 4.0 和物联网的快速发展&#xff0c;边缘计算作为连接云端与终端设备的关键技术&#xff0c;正成为推动数字化转型的核心力量。在边缘计算场景中&#xff0c;设备的实时性、低功耗和离线处理能力至关重要。ARM 架构凭借其低功耗、高能效的特点&#xff0c;成…

C# 基于 Windows 系统与 Visual Studio 2017 的 Messenger 消息传递机制详解:发布-订阅模式实现

&#x1f9d1; 博主简介&#xff1a;CSDN博客专家、CSDN平台优质创作者&#xff0c;高级开发工程师&#xff0c;数学专业&#xff0c;10年以上C/C, C#, Java等多种编程语言开发经验&#xff0c;拥有高级工程师证书&#xff1b;擅长C/C、C#等开发语言&#xff0c;熟悉Java常用开…

js数据类型有哪些?它们有什么区别?

js数据类型共有8种,分别是undefined,null,boolean,number,string,Object,symbol,bigint symbol和bigint是es6中提出来的数据类型 symbol创建后独一无二不可变的数据类型,它主要是为了解决出现全局变量冲突的问题 bigint 是一种数字类型的数据,它可以表示任意精度格式的整数,…

Vite打包优化实践:从分包到性能提升

前言: ​​​​​​​ 随着前端应用功能的增加&#xff0c;项目的打包体积也会不断膨胀&#xff0c;影响加载速度和用户体验。本文介绍了几种常见的打包优化策略&#xff0c;通过Vite和相关插件&#xff0c;帮助减少项目体积、提升性能&#xff0c;优化加载速度。 rollup-plugi…

C++语法系列之模板进阶

前言 本次会介绍一下非类型模板参数、模板的特化(特例化)和模板的可变参数&#xff0c;不是最开始学的模板 一、非类型模板参数 字面意思,比如&#xff1a; template<size_t N 10> 或者 template<class T,size_t N 10>比如&#xff1a;静态栈就可以用到&#…

html5的响应式布局的方法示例详解

以下是HTML5实现响应式布局的5种核心方法及代码示例: 1. 媒体查询(核心方案) /* 默认样式(移动优先) */ .container {padding: 15px; }/* 中等屏幕(平板) */ @media (min-width: 768px) {.container {padding: 30px;max-width: 720px;} }/* 大屏幕(桌面) */ @media …

数字化转型进阶:精读41页华为数字化转型实践【附全文阅读】

该文档聚焦华为数字化转型实践&#xff0c;核心内容如下&#xff1a; 转型本质与目标&#xff1a;数字化转型是通过数字技术穿透业务&#xff0c;实现物理世界与数字世界的融合&#xff0c;目标是支撑主业成功、提升体验与效率、探索模式创新。华为以 “平台 服务” 为核心&am…

C++ - STL #什么是STL #STL的版本 #闭源开源 #STL的六大组件

文章目录 前言 一、什么是STL 二、STL的版本 1、原始版本 2、P.J.版本 3、RW版本 4、SGI版本 三、闭源、开源 四、STL的六大组件 总结 前言 路漫漫其修远兮&#xff0c;吾将上下而求索&#xff1b; 一、什么是STL STL(standard template libaray 标准模板库)&#…

智慧康养护理:科技重塑老龄化社会的健康守护体系

在我国迈入深度老龄化社会的背景下&#xff0c;智慧康养护理作为融合科技与人文的创新模式&#xff0c;正成为提升老年人生活质量、减轻家庭照护压力、促进健康老龄化的重要路径。我们将从核心概念、关键技术、实际应用与未来趋势四个维度&#xff0c;为您呈现智慧康养护理的全…

权威认证与质量保障:第三方检测在科技成果鉴定测试中的核心作用

科技成果鉴定测试是衡量科研成果技术价值与应用潜力的关键环节&#xff0c;其核心目标在于通过科学验证确保成果的可靠性、创新性和市场适配性。第三方检测机构凭借其独立性、专业性和权威性&#xff0c;成为科技成果鉴定测试的核心支撑主体。本文从测试流程、第三方检测的价值…

Linux.docker.k8s基础概念

1.Linux基本命令 cat 查看文件内容。 cd 进入目标目录。 ll 查询当前路劲下文件的详细信息。 ls 查询当前路劲下的文件。 touch 建立一个文件。 mkdir 建立一个文件夹。 rm 删除文件或者目录。 mv 移动目录和重新命名文件。 unzip 解压。 top 查看当前线程的信息。 find …

Python小白的蜕变之旅:从环境搭建到代码规范(1/10)

摘要&#xff1a;全文围绕 Python 编程展开&#xff0c;先是介绍如何搭建 Python 开发环境&#xff0c;推荐使用 Anaconda 和 VSCode&#xff0c;并详细说明了二者的安装及配置步骤&#xff0c;包括安装 Anaconda、安装 VSCode 并配置 Python 插件、选择 Anaconda 的 Python 解…