【TCP传输数据】

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();
    }

}