package com.modbus.data; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import com.serotonin.modbus4j.serial.SerialPortWrapper; public class SerialPortWrapperImpl implements SerialPortWrapper{ private Socket socket; public SerialPortWrapperImpl(Socket socket){ this.socket = socket; } @Override public void close() throws Exception { if(null != socket) { this.socket.close(); } } @Override public int getBaudRate() { return 0; } @Override public int getDataBits() { return 0; } @Override public int getFlowControlIn() { return 0; } @Override public int getFlowControlOut() { return 0; } @Override public InputStream getInputStream() { if(null != socket) { try { return socket.getInputStream(); } catch (IOException e) { e.printStackTrace(); } } return null; } @Override public OutputStream getOutputStream() { if(null != socket) { try { return socket.getOutputStream(); } catch (IOException e) { e.printStackTrace(); } } return null; } @Override public int getParity() { return 0; } @Override public int getStopBits() { return 0; } @Override public void open() throws Exception { } public static void main(String[] args) { //SerialPortWrapperImpl impl = new SerialPortWrapperImpl(new Socket()); } }