server

package tcp;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TcpServerDemo1 {
    public static void main(String[] args) throws Exception {
        //監(jiān)聽8080端口
        ServerSocket serverSocket = new ServerSocket(8080);
        //等待客戶端連接
        Socket socket = serverSocket.accept();

        /*一般寫法
        //讀取客戶端消息
        InputStream is = socket.getInputStream();
        byte[] buffer = new byte[1024];
        int len;
        while ((len = is.read(buffer))!=-1){
            String msg = new String(buffer,0,len);
            System.out.println(msg);
        }
         */
        //管道流讀取法
        InputStream is = socket.getInputStream();
        ByteArrayOutputStream baos= new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        int len;
        while ((len = is.read(buffer))!=-1){
            baos.write(buffer,0,len);
        }
        System.out.println(baos.toString());

        //關(guān)閉流
        baos.close();
        is.close();
        socket.close();
        serverSocket.close();





    }
}

client

package tcp;

import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;


public class TcpClientDemo1 {
    public static void main(String[] args) throws Exception {
        //初始化服務(wù)器地址
        InetAddress serverIP =  InetAddress.getByName("127.0.0.1");
        //初始化端口號
        int port = 8080;
        //創(chuàng)建socket連接
        Socket socket = new Socket(serverIP,port);
        //發(fā)送消息
        OutputStream os = socket.getOutputStream();
        os.write("你好".getBytes());

        //關(guān)閉流
        os.close();
        socket.close();

    }
}