springboot中使用socket对接第三方接口

1、接口对接需求如下

1.1 socket协议
1.2 报文中数据均是左对齐右补空格
1.3 报文编码采用：GBK
1.4 接口文档：

2、代码

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.util.List;import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;public JSONObject testRequest(String userCode) throws IOException {logger.info("请求信息:{}",userCode);Socket socket = new Socket(ip, port);OutputStream os = socket.getOutputStream();byte[] param = byteMergerAll(fillParam("210", 3),//交易码fillParam(userCode, 10));//用户代码os.write(param);InputStream is = socket.getInputStream();byte[] result = new byte[1024];is.read(result);logger.info("响应信息:{},{}",new String(result, "GBK"));JSONObject resultJSON = new JSONObject();resultJSON.set("businessCode", new String(getByteByIndex(result, 0, 3)));//交易码resultJSON.set("code", new String(getByteByIndex(result, 4, 6)).trim());//响应码return resultJSON;}

3、涉及到的工具类

 /*** 合并多个byte数组** @param values* @return*/private byte[] byteMergerAll(byte[]... values) {int length_byte = 0;for (int i = 0; i < values.length; i++) {length_byte += values[i].length;}byte[] all_byte = new byte[length_byte];int countLength = 0;for (int i = 0; i < values.length; i++) {byte[] b = values[i];System.arraycopy(b, 0, all_byte, countLength, b.length);countLength += b.length;}return all_byte;}/*** 格式化参数** @param str* @param count* @return*/private byte[] fillParam(String str, int count) throws UnsupportedEncodingException {if (str.getBytes("GBK").length >= count) {return str.getBytes("GBK");}byte[] data = str.getBytes("GBK");byte[] empty = new byte[count - data.length];for (int i = 0; i < empty.length; i++) {empty[i] = 32;}return byteMergerAll(empty, data);}/*** 截取数组** @param original* @param begin* @param end* @return*/private byte[] getByteByIndex(byte[] original, int begin, int end) {byte[] result = new byte[end - begin + 1];int j = 0;for (int i = begin; i <= end; i++) {result[j] = original[i];j++;}return result;}

4、socket服务端本地测试工具

点击此处，下载socket工具

springboot中使用socket对接第三方接口相关推荐

java给第三方接口发送数据_对接第三方接口--使用post请求发送json数据
对接第三方接口–使用post请求发送json数据实习4个多月,终于转正!终于可以安心好好上班,好好学习!第一篇播客记录下工作中的中的小知识点. 本文记录的内容如下: 1.使用HttpClient相关 ...
SpringBoot中如何灵活的实现接口数据的加解密功能？
数据是企业的第四张名片,企业级开发中少不了数据的加密传输,所以本文介绍下SpringBoot中接口数据加密.解密的方式. 本文目录一.加密方案介绍二.实现原理三.实战四.测试五.踩到的坑一.加密方 ...
对接第三方接口（短信，支付）
前言第三方短信接口,支付接口广泛应用于金融领域与电商领域,这是我在14年工作时的一些经验总结,现在分享出来,希望能对一部分朋友有所帮助! 内容一:对接短信接口对接短信接口大体分为两个步骤: 1. ...
java对接第三方接口
1.准备与第三方接口对接的账号配置到了Apollo上面 @Value("${taofake.appId}")private String appId;@Value("$ ...
PHP研发对接第三方接口常用的一些方法函数
今天对了一下阿里云视频点播插件,用到了几个公共的方法函数,希望可以给同学们共同学习分享一下,对接其他的接口也可以用的到. 1.object转换array /***object转换array*@para ...
java 对接第三方接口
感想这是我第一次要写对外的接口,一开始还是比较迷茫的,因为要考虑到数据的安全传输,很多技术我都还是比较的不熟悉,后来经过对每一个技术的了解,终于还是写出来了. 感觉一切都是从陌生到熟悉,再到亲切哈 ...
解决对接第三方接口乱码问题
现代软件,程序员一般有两大任务: (1)自身业务,操作数据库 (2)外部业务,对接接口然,对接接口经常出现乱码问题. 以下是我用RestTemplate解决对接接口的乱码问题解决方案: public ...
vue+element对接第三方接口实现校园发帖网站“淘柳职”
一.前言项目演示地址:可私聊作者获取(演示地址不定时变化) 接上一篇博客<vue+elementui+java 前后端分离实现学校帖子网站,仿照"淘柳职"学校大作业> ...
SpringBoot中如何灵活的实现接口数据的加解密...
对接口的加密解密操作主要有下面两种方式: 自定义消息转换器优势:仅需实现接口,配置简单. 劣势:仅能对同一类型的MediaType进行加解密操作,不灵活. 使用spring提供的接口RequestB ...

springboot中使用socket对接第三方接口

1、接口对接需求如下

2、代码

3、涉及到的工具类

4、socket服务端本地测试工具

springboot中使用socket对接第三方接口相关推荐

最新文章

热门文章