TCP案例代码

Posted 技术很low的瓜贼

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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();
            

        
    


以上是关于TCP案例代码的主要内容,如果未能解决你的问题,请参考以下文章

生产环境下Linux内核参数优化案例代码

网络编程案例多任务版TCP服务端程序开发

Java系列讲座一:TCP方式Socket通信案例讲解

多任务版TCP服务端程序开发案例+源码

编写案例分别使用多进程多路复用(selectepoll)实现tcp服务

12.7 网络编程案例