tobacco-server-develop.zip

package com.kunming.socket.tobaccoserver.communicate.server; import com.kunming.socket.tobaccoserver.communicate.CustomSocketConnICC; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.Arrays; /** * @日期： 2022/9/17 @作者： 离染 * @描述：多线程下接收并响应烟叶连接*/ @Slf4j public class ReceiveRspServerRunnable implements Runnable { private Socket socket;//和本线程相关的Socket private Integer portIcc; InputStream inputStream=null; OutputStream outputStream=null; /** * @日期： 2022/9/19 @作者： 离染 * @描述：*/ public ReceiveRspServerRunnable(Socket socket, Integer portIcc) { this.socket = socket; this.portIcc=portIcc; } @Override public void run() { try { //接收烟叶数据：超时或报文长度等于头长度+90才停止接收 byte[] messageSumByte=receivingData(); CustomSocketConnICC customSocketConnICC =new CustomSocketConnICC(); byte[] receIccData=messageSumByte.length>0? customSocketConnICC.sendAndReceiveMessage(messageSumByte,portIcc): "接收数据为空".getBytes(); //发送响应报文 sendData(receIccData); } catch (Exception e) { e.printStackTrace(); }finally { try { if(outputStream!=null) outputStream.close(); if(inputStream!=null)inputStream.close(); if(socket!=null)socket.close(); } catch (IOException e) { throw new RuntimeException(e); } } } /** * @日期： 2022/9/19 @作者： 离染 * @描述：接收烟叶数据：已接收数据长度符合预期，或者接收超时，放弃等待，否则一直接收 */ @SneakyThrows private byte[] receivingData(){ //与客户端建立通信，获取输入流，读取取客户端提供的信息 inputStream = socket.getInputStream(); int length = inputStream.available(); log.info("[烟叶<->本机]将接收数据长度:{}",length); byte[] messageSumByte=new byte[0]; int byteLen=0; long start=System.currentTimeMillis(); while (true){ if(length==0){ if ((System.currentTimeMillis() - start) > 60* 1000) {//超时退出 log.info("[烟叶<->本机]接收烟叶数据,接收数据超时,"); return "接收烟叶数据超时".getBytes(); } Thread.sleep(100); inputStream = socket.getInputStream(); length=inputStream.available(); continue; } byte[] bytes=new byte[length]; inputStream.read(bytes); log.info("[烟叶<->本机]当前接收数据长度:{},数据:{}",bytes.length,new String(bytes)); String headStr = new String(bytes); String versionType=headStr.substring(0,6); if(length>14 && "1.0001".equals(versionType)){ String messageLengthStr=headStr.substring(6,14); byteLen=Integer.parseInt(messageLengthStr) + 90; } byte[] result = Arrays.copyOf(messageSumByte, messageSumByte.length + bytes.length); System.arraycopy(bytes, 0, result, messageSumByte.length, bytes.length); messageSumByte=result; log.info("[烟叶<->本机]当前长度:{},报文总长度:{},预期长度:{}",bytes.length,messageSumByte.length,byteLen); if(messageSumByte.length==byteLen){break;} inputStream = socket.getInputStream(); length=inputStream.available(); } log.info("[烟叶<->本机]接收烟叶数据完毕,接收全部数据为:{}",new String(messageSumByte)); socket.shutdownInput();//关闭输入流 return messageSumByte; } @SneakyThrows private void sendData(byte[] rspMessage){ //获取输出流，响应客户端的请求 outputStream = socket.getOutputStream(); log.info("[烟叶<->本机]开发返回数据."); if(rspMessage==null||rspMessage.length==0){ rspMessage="未知错误".getBytes(); } outputStream.write(rspMessage); outputStream.flush(); outputStream.close(); // socket.shutdownOutput(); log.info("[烟叶<->本机]发送数据完毕."); } }