java基于C/S结构实现多线程聊天室

Z时代
2024-01-10
分类：综合

本文实例为大家分享了java基于C/S结构实现多线程聊天室的具体代码，供大家参考，具体内容如下

主要实现的功能：

服务器端建立ServerSocket阻塞监听来自客户端的Socket连接，并为之开辟一个新的线程

读取来自该连接的数据，广播每一个客户端数据，这里简单地使用一个链表保存所有来自客户端的所有Socket连接

客户端连接上服务器端后主要有两个线程在工作：

主线程：不断获取键盘的输入并写入该Socket中传输给服务器

副线程：不断从服务器Socket流中读取传来的数据，打印到屏幕上。

服务器端代码：


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.ArrayList;
import javax.swing.JOptionPane;
public class MyServer {
 public static ArrayList<Socket> socketlist = new ArrayList<Socket>();
 private static String port ;
 public static void main(String[] args) throws IOException
 {
 //弹出一个对话框输入端口号
 port = JOptionPane.showInputDialog("input the port number: ");
 int ServerPort = new Integer(port).intValue();
 ServerSocket ss = new ServerSocket(ServerPort);
 System.out.println("Server is initializating...");
 while(true)
 {
 System.out.println("Server is waiting...");
 //此处将阻塞监听
 Socket s = ss.accept();
 System.out.println("listening from: " + s.getInetAddress());
 socketlist.add(s);
 new Thread(new ServerThread(s)).start();
 }
 }
}
class ServerThread implements Runnable
{
 Socket s = null;
 BufferedReader br = null;
 public ServerThread(Socket s) throws IOException
 {
 this.s = s;
 br = new BufferedReader(new InputStreamReader(s.getInputStream()));
 }
 public void run()
 {
 try
 {
 String content = null;
 while( (content = readFromClient()) != null )
 {
 //播报每个客户端数据
 for(Socket s : MyServer.socketlist)
 {
 PrintStream ps = new PrintStream(s.getOutputStream());
 ps.println(content);
 }
 }
 }
 catch (IOException io) 
 {
 io.printStackTrace();
 }
 }
 private String readFromClient()
 {
 try
 {
 return br.readLine();
 }
 catch (IOException io)
 {
 MyServer.socketlist.remove(s);
 System.out.println(s.getInetAddress() + " is disconnecting...");
 }
 return null;
 }
}

客户端代码：


import java.net.Socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
public class MyClient {
 public static void main(String[] args) throws Exception
 {
 Socket s = new Socket("192.168.1.164", 30000);
 // new Thread to read content from server.
 new Thread(new ClientThread(s)).start();
 PrintStream ps = new PrintStream(s.getOutputStream());
 String line = null;
 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
 while((line = br.readLine()) != null)
 {
 ps.println(line);
 }
 }
}
class ClientThread implements Runnable
{
 private Socket s = null;
 BufferedReader br = null;
 public ClientThread(Socket s) throws IOException
 {
 this.s = s;
 br = new BufferedReader(new InputStreamReader(s.getInputStream()));
 }
 public void run()
 {
 try
 {
 String content = null;
 while( (content = br.readLine()) != null)
 {
 System.out.println(content);
 }
 }
 catch (IOException io)
 {
 io.printStackTrace();
 }
 }
}