（三）socket·socket 实现控制台一问一答式聊天

た入场券 2022-04-23 10:30 247阅读 0赞

### 文章目录 ###

*   *   *   *   *  前言
                 *  在 IDE 实现一问一答式聊天
                 *  代码
                 *   *  服务端
                     *  客户端
                     *  效果
                 *  跨越局域网实现远程访问本地

##### 前言 #####

> socket 是全双工传输模式，在不启用多线程的情况下，这种功效并不能立即体现出来，即客户端发送-服务端接收-服务端发送-客户端接收需要有序进行。

##### 在 IDE 实现一问一答式聊天 #####

> 如果你有一个程序员朋友，懂一点 Java 开发，恰巧他/她的电脑安装有 eclipse 或者 idea ，那么可以借助于本文的代码在你们的 ide 里实现一问一答式的聊天。  
> 每次只能说一句，不限制交互次数。

##### 代码 #####

> 服务端和客户端都只是一个类，运行各自的 main 方法即可。  
> 需要注意的是客户端指定服务器端的 ip 和 端口。  
> 注意客户端和服务器端对字符流的处理编码格式需要一致，否则会出现乱码。  
> 使用了线程池  
> 客户端和服务器端单独指定了编码格式为 UTF8  
> 服务器端和客户端每次输入都自动添加 end 作为发送结束，接收端以此进行判断

###### 服务端 ######

import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.nio.charset.Charset;
    import java.util.Scanner;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /** * socket 服务端 * 一问一答式 * @Author: jie.wu */
    public class ChatServer { 
        //使用线程池
        private static ExecutorService threadPool= Executors.newFixedThreadPool(5);
    
        //编码格式
        private final static String charset="UTF8";
        public static void main(String [] args){ 
            ServerSocket serverSocket=null;
            Scanner s=new Scanner(System.in);
            try{ 
                serverSocket=new ServerSocket(10000);//端口使用 10000
                System.out.println("服务端已启动，您本地的字符格式为"+Charset.defaultCharset().name()+"，等待客户端访问");
    
                //接收客户端的访问,不限制访问次数
                for(;;){ 
                    Socket client=serverSocket.accept();
                    threadPool.execute(new ServerThread(client,s));
                }
            }catch(Exception e){ 
                System.out.println("报错了1"+e);
            }
        }
    
        public static class ServerThread implements Runnable{ 
            private Socket socket;//客户端
            private Scanner s;
            public ServerThread(Socket socket,Scanner s){ 
                this.socket=socket;
                this.s=s;
            }
            InputStream inputStream=null;
            BufferedReader bufferedReader=null;
            PrintWriter printWriter=null;
    
            @Override
            public void run() { 
                //客户端声明
                Socket clientSocket=null;
                //客户端输入流声明
                InputStream inputStream=null;
                BufferedReader bufferedReader =null;
                //客户端输出流声明
                OutputStream outputStream=null;
                PrintWriter printWriter=null;
                try{ 
                    //初始化客户端
                    clientSocket=socket;
                    //初始化客户端输入流
                    inputStream=clientSocket.getInputStream();
                    //读取客户端传输的内容
                    bufferedReader = new BufferedReader(new InputStreamReader(inputStream, charset));
    
                    //输出
                    String str="";
                    System.out.print("客户端输入：");
                    //避免使用 readLine 容易造成 阻塞
    
                    //服务端会阻塞，使用 readline 方法
                    for(;(str=bufferedReader.readLine())!=null;){ 
                        if("end".equals(str)){ 
                            break;
                        }
                        System.out.print(str);
                    }
                    System.out.println();
                /* char b[]=new char[8192]; StringBuffer sbf=new StringBuffer(); for(int n=0;(n=bufferedReader.read(b,0,n))!=-1;){ sbf.append(b); } System.out.println(sbf.toString()); */
                    //初始化客户端输出流
                    outputStream=clientSocket.getOutputStream();
    
                    printWriter=new PrintWriter(new OutputStreamWriter(outputStream,charset),true);
                    //printWriter.println("你好，我是服务器端");
                    System.out.print("请你输入：");
                    Scanner s=new Scanner(System.in);
                    printWriter.println(s.nextLine()+System.getProperty("line.separator")+"end");
                    System.out.println();
                }catch(Exception e){ 
                    System.out.println("服务器报错"+e);
                }finally { 
                    try{ 
                        if(inputStream!=null){ 
                            inputStream.close();
                        }
                        if(bufferedReader!=null){ 
                            bufferedReader.close();
                        }
                        if(outputStream!=null){ 
                            outputStream.close();
                        }
                        if(printWriter!=null){ 
                            printWriter.close();
                        }
                    }catch(Exception e){ 
                        System.out.println("服务器真的报错了"+e);
                    }
                }
            }
        }
    }

###### 客户端 ######

import java.io.*;
    import java.net.InetSocketAddress;
    import java.net.Socket;
    import java.nio.charset.Charset;
    import java.util.Scanner;
    
    /** * socket * 一问一答式 * 客户端 * @Author: jie.wu */
    public class Client { 
        private final static String charset="UTF8";
    
        public static void main(String [] args){ 
            System.out.println("客户端已启动，您本地的字符格式为"+Charset.defaultCharset().name()+"，请输入信息：");
            Client c=new Client();
            //接收客户端的访问-交互20次
            for(int i=0;i<20;i++){ 
                c.client();
            }
        }
    
        public void client(){ 
            Scanner s=new Scanner(System.in);
            Socket socket=new Socket();
            OutputStream outputStream=null;
            PrintWriter printWriter=null;
            InputStream inputStream=null;
            BufferedReader bufferedReader=null;
            try { 
                //服务端ip和端口
                socket.connect(new InetSocketAddress("127.0.0.1", 10000));
                //socket.connect(new InetSocketAddress("server.natappfree.cc",36574));
                outputStream=socket.getOutputStream();
    
                printWriter=new PrintWriter(new OutputStreamWriter(outputStream, charset),true);
                //printWriter.println("你好，我是客户端");
                System.out.print("请你输入：");
                printWriter.println(s.nextLine()+System.getProperty("line.separator")+"end");
                //printWriter.println(s.nextLine());
                //printWriter.println("end");
                //printWriter.println("end");
                inputStream=socket.getInputStream();
                bufferedReader=new BufferedReader(new InputStreamReader(inputStream,charset));
                //readLine 会造成服务器端阻塞，服务器端要么加以判断主动关闭，要么等待客户端，要么新起一个线程
                String str="";
                System.out.print("服务端返回：");
                for(;(str=bufferedReader.readLine())!=null;){ 
                    if("end".equals(str)){ 
                        break;
                    }
                    System.out.print(str);
                }
                System.out.println();
                /* char[] b=new char[8192]; StringBuffer sbf=new StringBuffer(); for(int n=0;(n=bufferedReader.read(b,0,n))>-1;){ sbf.append(b); } System.out.println(sbf.toString()); */
            }catch(Exception e){ 
                System.out.println("报错了"+e);
            }finally { 
                try{ 
                    if(outputStream!=null){ 
                        outputStream.close();
                    }
                    if(printWriter!=null){ 
                        printWriter.close();
                    }
                    if(inputStream!=null){ 
                        inputStream.close();
                    }
                    if(bufferedReader!=null){ 
                        bufferedReader.close();
                    }
                }catch(Exception e){ 
                    System.out.println("真的报错了"+e);
                }
            }
        }
    }

###### 效果 ######

服务端  
![在这里插入图片描述][20190208145500393.png]  
客户端  
![在这里插入图片描述][20190208145518613.png]

##### 跨越局域网实现远程访问本地 #####

> 一般我们只有一个内网 ip ，这样不足以使远方端朋友运用上面端代码来和我们进行聊天，借助于一个工具，可以将内网 ip 映射到一个临时域名，从而让客户端通过这个临时域名来进行远程访问。  
> 可以获得一个免费的资格  
> [https://blog.csdn.net/bestcxx/article/details/82182107][https_blog.csdn.net_bestcxx_article_details_82182107]  
> 注意使用 socket 的时候选择 TCP  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Jlc3RjeHg_size_16_color_FFFFFF_t_70]

[20190208145500393.png]: /images/20220321/cdae040726604ba894d7db101e542a8d.png
[20190208145518613.png]: /images/20220321/5951ca98c62b49adb1fb4abc0addb276.png
[https_blog.csdn.net_bestcxx_article_details_82182107]: https://blog.csdn.net/bestcxx/article/details/82182107
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Jlc3RjeHg_size_16_color_FFFFFF_t_70]: /images/20220321/fb34fe693d2a42358e4a053e8b48500d.png