package com.yjf.esupplier.common.test;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.Socket;/** * @author shusheng * @description TCP 传输数据 * @Email shusheng@yiji.com * @date 2019/1/15 22:57 */public class ClientDemo {    public static void main(String[] args) throws IOException {        // 创建发送端的Socket对象        Socket socket = new Socket("localhost",8888);        OutputStream outputStream = socket.getOutputStream();        outputStream.write("hello tcp,我来啦".getBytes());        // 获取输入流        InputStream is = socket.getInputStream();        byte[] bys = new byte[1024]; int len = is.read(bys);// 阻塞        String client = new String(bys, 0, len); System.out.println("client:" + client);        socket.close();    }}

package com.yjf.esupplier.common.test;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;/** * @author shusheng * @description TCP 传输数据 * @Email shusheng@yiji.com * @date 2019/1/16 21:11 */public class ServerDemo {    public static void main(String[] args) throws IOException {        // 创建接收端的 Socket 对象        ServerSocket ss = new ServerSocket(8888);        Socket s = ss.accept();        InputStream is = s.getInputStream();        byte[] bys = new byte[1024];        int len = is.read(bys);        String str = new String(bys, 0, len);        String ip = s.getInetAddress().getHostAddress();        System.out.println(ip + "---" + str);        // 获取输出流        OutputStream os = s.getOutputStream();        os.write("数据已经收到".getBytes());        s.close();    }}