public class demo {
    public static void main(String[] args) throws Exception{
        // 監(jiān)聽指定的端口
        int port = 55533;
        ServerSocket server = new ServerSocket(port);
        // server將一直等待連接的到來
        System.out.println("server將一直等待連接的到來");
        Socket socket = server.accept();
        // 建立好連接后，從socket中獲取輸入流，并建立緩沖區(qū)進(jìn)行讀取
        InputStream inputStream = socket.getInputStream();
        byte[] bytes = new byte[1024];
        int len;
        StringBuilder sb = new StringBuilder();
        //只有當(dāng)客戶端關(guān)閉它的輸出流的時(shí)候，服務(wù)端才能取得結(jié)尾的-1
        while ((len = inputStream.read(bytes)) != -1) {
            // 注意指定編碼格式，發(fā)送方和接收方一定要統(tǒng)一，建議使用UTF-8
            sb.append(new String(bytes, 0, len, "UTF-8"));
        }
        System.out.println("get message from client: " + sb);
        OutputStream outputStream = socket.getOutputStream();
        outputStream.write("客戶端,我收到信息了".getBytes("UTF-8"));
        inputStream.close();
        outputStream.close();
        socket.close();
        server.close();
    }
}

@Slf4j
public class demo1 {
    public static void main(String[] args) throws Exception {
        String serverIP = "127.0.0.1";
        int port = 55533;
        int timeOut = 10000;
        String data = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" +
                "<SERVICE>\n" +
                "    <prcscd>mbr128</prcscd>\n" +
                "    <servtp>MBL</servtp>\n" +
                "    <datasq>CNT2018092500000000001</datasq>\n" +
                "    <servsq>20180206000000000001</servsq>\n" +
                "    <userid>0170901</userid>\n" +
                "    <brchno>017001</brchno>\n" +
                "    <servdt>20180925</servdt>\n" +
                "    <servti>165125</servti>\n" +
                "    <ipaddr>10.28.25.30</ipaddr>\n" +
                "    <mac>D4-BE-D9-A2-39-EF</mac>\n" +
                "    <acctno>100633778400041</acctno>\n" +
                "</SERVICE>";
        // 與服務(wù)端建立連接
        Socket socket = new Socket(serverIP, port);
        //設(shè)置超時(shí)時(shí)間
        socket.setSoTimeout(timeOut);
        // 建立連接后獲得輸出流
        OutputStream outputStream = socket.getOutputStream();
        socket.getOutputStream().write(data.getBytes("UTF-8"));
        //通過shutdownOutput高速服務(wù)器已經(jīng)發(fā)送完數(shù)據(jù)，后續(xù)只能接受數(shù)據(jù)
        socket.shutdownOutput();
        InputStream inputStream = socket.getInputStream();
        byte[] bytes = new byte[1024];
        int len;
        StringBuilder sb = new StringBuilder();
        while ((len = inputStream.read(bytes)) != -1) {
            //注意指定編碼格式，發(fā)送方和接收方一定要統(tǒng)一，建議使用UTF-8
            sb.append(new String(bytes, 0, len,"UTF-8"));
        }
        System.out.println("收到響應(yīng)報(bào)文: " + sb);
        inputStream.close();
        outputStream.close();
        socket.close();
    }
}