java的socket請求和響應方式

更新時間：2023年09月28日 10:01:20 作者：zhao_854093140

這篇文章主要介紹了java的socket請求和響應方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

java的socket請求和響應

創(chuàng)建一個socket的server端

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ū)進行讀取
        InputStream inputStream = socket.getInputStream();
        byte[] bytes = new byte[1024];
        int len;
        StringBuilder sb = new StringBuilder();
        //只有當客戶端關閉它的輸出流的時候，服務端才能取得結尾的-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();
    }
}

再創(chuàng)建一個socket的client端

@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>";
        // 與服務端建立連接
        Socket socket = new Socket(serverIP, port);
        //設置超時時間
        socket.setSoTimeout(timeOut);
        // 建立連接后獲得輸出流
        OutputStream outputStream = socket.getOutputStream();
        socket.getOutputStream().write(data.getBytes("UTF-8"));
        //通過shutdownOutput高速服務器已經(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("收到響應報文: " + sb);
        inputStream.close();
        outputStream.close();
        socket.close();
    }
}

首先運行server端，然后再運行client端

這個時候看控制的打印

先看server端的控制臺，這時收到了clietn端發(fā)來的信息