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();

									 }

									}