文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

怎么在Java中使用Socket实现一个多人聊天室

2023-06-14 10:39

关注

本篇文章给大家分享的是有关怎么在Java中使用Socket实现一个多人聊天室,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。

流程

值得一提是:该Socket是同步阻塞的,因此在socket客户端需要进行创建一个线程,来分别进行向服务器输出,和接收服务器传输的数据。要解决同步阻塞这个问题可以去了解JAVA NIO。

Socket客户端代码如下:

import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.Socket; public class Client{  public static void main(String[] args) throws IOException { //创建连接指定Ip和端口的socket Socket socket = new Socket("127.0.0.1",5200); //获取系统标准输入流 BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); PrintWriter out = new PrintWriter(socket.getOutputStream()); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); //创建一个线程用于读取服务器的信息 new Thread(new Runnable() {  @Override  public void run() {  try {   while (true){   System.out.println(in.readLine());   }  } catch (IOException e) {   e.printStackTrace();  }  } }).start(); //写信息给客户端 String line = reader.readLine(); while (!"end".equalsIgnoreCase(line)){  //将从键盘获取的信息给到服务器  out.println(line);  out.flush();  //显示输入的信息  line = reader.readLine(); } out.close(); in.close(); socket.close();  }}

由于要接收多个客户端的请求,因此服务端需要多个线程进行分别来接收客户端的请求。

Socket服务端代码如下:

import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.List;import java.util.Vector; public class Servers { //将接收到的socket变成一个集合 protected static List<Socket> sockets = new Vector<>();  public static void main(String[] args) throws IOException { //创建服务端 ServerSocket server = new ServerSocket(5200); boolean flag = true; //接受客户端请求 while (flag){  try {  //阻塞等待客户端的连接  Socket accept = server.accept();  synchronized (sockets){  sockets.add(accept);  }  //多个服务器线程进行对客户端的响应  Thread thread = new Thread(new ServerThead(accept));  thread.start();  //捕获异常。  }catch (Exception e){  flag = false;  e.printStackTrace();  } } //关闭服务器 server.close(); } }

Server线程代码如下:

import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.Socket; public class ServerThead extends Servers implements Runnable{  Socket socket; String socketName;  public ServerThead(Socket socket){ this.socket = socket; } @Override public void run() { try {  BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));  //设置该客户端的端点地址  socketName = socket.getRemoteSocketAddress().toString();  System.out.println("Client@"+socketName+"已加入聊天");  print("Client@"+socketName+"已加入聊天");  boolean flag = true;  while (flag)  {  //阻塞,等待该客户端的输出流  String line = reader.readLine();  //若客户端退出,则退出连接。  if (line == null){   flag = false;   continue;  }  String msg = "Client@"+socketName+":"+line;  System.out.println(msg);  //向在线客户端输出信息  print(msg);  }   closeConnect(); } catch (IOException e) {  try {  closeConnect();  } catch (IOException e1) {  e1.printStackTrace();  } } }  private void print(String msg) throws IOException { PrintWriter out = null; synchronized (sockets){ for (Socket sc : sockets){  out = new PrintWriter(sc.getOutputStream());  out.println(msg);  out.flush(); } } }  public void closeConnect() throws IOException { System.out.println("Client@"+socketName+"已退出聊天"); print("Client@"+socketName+"已退出聊天"); //移除没连接上的客户端 synchronized (sockets){  sockets.remove(socket); } socket.close(); }}

由于要接收多个客户端的信息,并转发到每一个已经连接上的客户端,因此创建了一个Vector集合来保存每一个客户端Socket,由于是多个线程同时对这个Vector集合进行操作,因此加上synchronized关键字保证同步安全。

先运行服务器端,然后在运行多个客户端就可以进行多人聊天了。

下面是运行的结果。

怎么在Java中使用Socket实现一个多人聊天室 

客户端2

怎么在Java中使用Socket实现一个多人聊天室 

客户端1

怎么在Java中使用Socket实现一个多人聊天室 

客户端3

怎么在Java中使用Socket实现一个多人聊天室

以上就是怎么在Java中使用Socket实现一个多人聊天室,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注编程网行业资讯频道。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯