TCP案例代码

文章目录

• TCP网络编程的案例代码
• • 普通服务端/客户端代码
  • 多线程方式代码

TCP网络编程的案例代码

描述客户端与服务端的通信

普通服务端/客户端代码

• 服务端

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务端
 */
public class ServerSocketTest {

    public static void main(String[] args) {
        ServerSocket ss = null;
        Socket s = null;
        // BufferedInputStream bis = null;
        BufferedReader br = null;
        PrintStream ps = null;
        try {
            // 创建ServerSocket类型的对象并提供端口号
            ss = new ServerSocket(8888);
            System.out.println("正在等待连接");
            // 等待客户端的链接请求 调用accept方法
            s = ss.accept();
            System.out.println("客户端链接成功");
            // 使用输入输出流进行通信
            // bis = new BufferedInputStream(s.getInputStream());  // 获取汉字出现乱码
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));
            ps = new PrintStream(s.getOutputStream());
            while (true) {
                System.out.println("获取到服务端的内容为");
                String s1 = br.readLine();
                System.out.println(s1); // 此处使用read()会使得回车无法解析，无法终止
                System.out.println("接收成功");
                System.out.println("服务器给客户端发送消息");
                ps.println("服务端收到！！！！");
                if (s1.equals("bye")) {
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (null != ps) {
                ps.close();
            }
            // 关闭Socket并释放有关资源
            if (null != s) {
                try {
                    s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != ss) {
                try {
                    ss.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }
    }
}

• 客户端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * 客户端
 */
public class SocketTest {

    public static void main(String[] args) {
        // 创建Socket类型的对象并提供服务端的主机名和端口号
        Socket s = null;
        PrintStream ps = null;
        Scanner sc = null;
        BufferedReader br = null;
        try {
            s = new Socket("Myd0130", 8888);
            System.out.println("链接服务器成功");
            Thread.sleep(5000);
            sc = new Scanner(System.in);
            // 使用输入输出流进行通信
            // 客户端向服务端发送消息
            ps = new PrintStream(s.getOutputStream());
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));

            while (true) {
                System.out.println("请输入要发送内容");
                String str = sc.next();
                ps.println(str);
                if (str.equals("bye")) {
                    break;
                }
                System.out.println("发送内容成功");
                System.out.println("接收到的消息为");
                String s1 = br.readLine();
                System.out.println(s1);
            }
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != s) {
                try {
                    // 关闭Socket对象，并释放相关资源
                    s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != sc) {
                sc.close();
            }
            if (null != ps) {
                ps.close();
            }

        }
    }
}

多线程方式代码

• 多线程

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务端
 */
public class ThreadsSocket implements Runnable{

    private Socket s;

    public ThreadsSocket(Socket s) {
        this.s = s;
    }
    @Override
    public void run() {
        BufferedReader br = null;
        PrintStream ps = null;
        try {
            // 3.使用输入输出流进行通信
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));
            ps = new PrintStream(s.getOutputStream());
            while(true) {
                // 实现对客户端发来字符串内容的接收并打印
                // 当没有数据发来时，下面的方法会形成阻塞
                String s1 = br.readLine();
                InetAddress inetAddress = s.getInetAddress();
                System.out.println("客户端" + inetAddress + "发来的字符串内容是：" + s1);
                // 当客户端发来的内容为"bye"时，则聊天结束
                if ("bye".equalsIgnoreCase(s1)) {
                    System.out.println("客户端" + inetAddress + "已下线！");
                    break;
                }
                // 实现服务器向客户端回发字符串内容"I received!"
                ps.println("I received!");
                System.out.println("服务器发送数据成功！");
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (null != ps) {
                ps.close();
            }
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != s) {
                try {
                    s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

• 服务端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务端
 */
public class StartTest {

    public static void main(String[] args) {
        ServerSocket ss = null;
        Socket s = null;
        try {
            // 创建ServerSocket类型的对象并提供端口号
            ss = new ServerSocket(8888);
            System.out.println("正在等待连接");
            // 等待客户端的链接请求 调用accept方法
            System.out.println("等待连接请求");
            while (true) {
                s = ss.accept();
                System.out.println("客户端链接成功");
                ThreadsSocket threadsSocket = new ThreadsSocket(s);
                Thread t = new Thread(threadsSocket);
                t.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 关闭Socket并释放有关资源
            if (null != s) {
                try {
                    s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != ss) {
                try {
                    ss.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

• 客户端（多复制几份即可描述多个客户端）

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

/**
 * 客户端
 */
public class SocketTest1 {

    public static void main(String[] args) {
        // 创建Socket类型的对象并提供服务端的主机名和端口号
        Socket s = null;
        PrintStream ps = null;
        Scanner sc = null;
        BufferedReader br = null;
        try {
            s = new Socket("Myd0130", 8888);
            InetAddress inetAddress = s.getInetAddress();
            System.out.println(inetAddress + "连接服务器成功");
            Thread.sleep(5000);
            sc = new Scanner(System.in);
            // 使用输入输出流进行通信
            // 客户端向服务端发送消息
            ps = new PrintStream(s.getOutputStream());
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));

            while (true) {
                System.out.println("请输入要发送内容");
                String str = sc.next();
                ps.println(str);
                if (str.equals("bye")) {
                    break;
                }
                System.out.println("发送内容成功");
                System.out.println("接收到的消息为");
                String s1 = br.readLine();
                System.out.println(s1);
            }
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != s) {
                try {
                    // 关闭Socket对象，并释放相关资源
                    s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != sc) {
                sc.close();
            }
            if (null != ps) {
                ps.close();
            }

        }
    }
}