java的socket请求和响应

首先创建一个socket的server端

public class demo {

    public static void main(String[] args) throws Exception{

        // 监听指定的端口
        int port = 55533;
        ServerSocket server = new ServerSocket(port);

        // server将一直等待连接的到来
        System.out.println("server将一直等待连接的到来");
        Socket socket = server.accept();
        // 建立好连接后，从socket中获取输入流，并建立缓冲区进行读取
        InputStream inputStream = socket.getInputStream();
        byte[] bytes = new byte[1024];
        int len;
        StringBuilder sb = new StringBuilder();
        //只有当客户端关闭它的输出流的时候，服务端才能取得结尾的-1
        while ((len = inputStream.read(bytes)) != -1) {
            // 注意指定编码格式，发送方和接收方一定要统一，建议使用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();
    }
}

然后再创建一个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高速服务器已经发送完数据，后续只能接受数据
        socket.shutdownOutput();

        InputStream inputStream = socket.getInputStream();
        byte[] bytes = new byte[1024];
        int len;
        StringBuilder sb = new StringBuilder();
        while ((len = inputStream.read(bytes)) != -1) {
            //注意指定编码格式，发送方和接收方一定要统一，建议使用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端发来的信息
然后再看client端,看看server的返回信息是否有接收到
这样,一个socket的请求就结束了,这么的demo中的代码可以直接复用,只需将ip,port还有超时时间换了即可