Java中的TCP通信简单使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author: LJ
 * @description：TCP服务端简单实现
 **/
public class TCP_Server {
    public static void main(String[] args)throws IOException
    {
        //监听端口
        int port = 30000;
        //创建一个ServerSocket, 用于监听客户端Socket的连接请求
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("server启动成功，等待客户端连接...");

        //server等待连接的到来
        Socket socket = serverSocket.accept();
        //将Socket对应的输出流包装成printStream
        PrintStream ps = new PrintStream(socket.getOutputStream());
        ps.println("You have received message form server!");

        InputStream inputStream = socket.getInputStream();
        byte[] bytesFromClient = new byte[1024];
        int len = 0;
        StringBuilder sb = new StringBuilder();
        while ((len = inputStream.read(bytesFromClient))!=-1){
            sb.append(new String(bytesFromClient, 0 , len));
        }
        System.out.println("get message from client: "+ sb.toString());

        //关闭输出流，关闭socket
        inputStream.close();
        ps.close();
        socket.close();
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * @author: LJ
 * @description：TCP客户端简单实现
 **/
public class TCP_Client {
    public static void main(String[] args) throws IOException {
        InputStream is = null;
        InputStreamReader isr = null;
        BufferedReader br = null;
        OutputStream os = null;
        OutputStreamWriter osw = null;
        PrintWriter pw = null;
        try{
            //建立连接
            Socket socket = new Socket("localhost", 30000);
            System.out.println("开启Socket线程");
            //获取字节输出流
            os = socket.getOutputStream();
            //将输出流包装为打印流
            pw = new PrintWriter(os);
            pw.write("Hi server! This is message from client!");
            pw.flush();
            //关闭输出流
            socket.shutdownOutput();
            //获取字节输入流
            is=socket.getInputStream();
            br=new BufferedReader(new InputStreamReader(is));
            String message =null;
            while ((message = br.readLine())!=null){
                System.out.println("我是客户端，服务器返回消息："+message);
            }

            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            br.close();
            is.close();
            pw.close();
            os.close();
        }
    }
}

1
2
server启动成功，等待客户端连接...

1
2
3
server启动成功，等待客户端连接...
get message from client: Hi server! This is message from client!

1
2
3
开启Socket线程
我是客户端，服务器返回消息：You have received message form server!