Java通过Socket实现简单多人聊天室

本文实例为大家分享了java通过socket实现多人聊天室的具体代码，供大家参考，具体内容如下

socket可以实现网络上两个程序通过双向通道进行数据的交换，此外它是java中网络tcp/ip协议的封装，例如可以进行网络通信等等，下面我们就来简单写一下多人聊天室。

首先来分析一下要实现的流程

• 首先建立一个服务器端，构建serversocket并绑定端口
• 创建socket客户端，连接到指定ip以及其端口
• 然后使用accept阻塞接收socket发出的连接请求
• 获取连接后的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();
  }
 }
 }
 /**
 * 向所有在线客户端socket转发消息
 * @param msg
 * @throws ioexception
 */
 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();
 }
 }
 }
 /**
 * 关闭该socket的连接
 * @throws ioexception
 */
 public void closeconnect() throws ioexception {
 system.out.println("client@"+socketname+"已退出聊天");
 print("client@"+socketname+"已退出聊天");
 //移除没连接上的客户端
 synchronized (sockets){
  sockets.remove(socket);
 }
 socket.close();
 }
}

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

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

下面是运行的结果。

 

客户端2

 

客户端1

 

客户端3

服务端

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。