Java Socket实现简易聊天室
作者:快乐键盘侠
这篇文章主要为大家详细介绍了Java Socket实现简易聊天室,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
Java-Socket编程实现简易聊天室(TCP),供大家参考,具体内容如下
实现一个服务器接收多个客户端
测试:
首先启动服务器,然后启动三个客户端,输入三个不同的用户名,分别在聊天室发消息
看其他客户端是否能接收到消息
效果如下图:
一号发消息
可以在二号和三号客户端接收到消息
服务器设计
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Server1 { static public List<Client> list = new ArrayList<Client>(); static ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); public static void main(String[] args) { //创建一个ServerSocket监听端口 try (ServerSocket server = new ServerSocket(5678)) { while (true) { // 利用死循环不停的监听端口 Socket s = server.accept();// 利用Socket服务器的accept()方法获取客户端Socket对象。 addClient(s); } } catch (IOException e) { e.printStackTrace(); } } // 添加客户端 private static void addClient(Socket s) { String name; try { BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream())); name = in.readLine(); Client c = new Client(name, s);// 创建客户端处理线程对象 System.out.println(name); list.add(c); cachedThreadPool.execute(c); } catch (IOException e) { e.printStackTrace(); } } static class Client implements Runnable { String name; // 客户端名字 Socket s = null; // 保存客户端Socket对象 BufferedReader in; PrintWriter out; Client(String name, Socket s) { this.s = s; this.name = name; try { in = new BufferedReader(new InputStreamReader(s.getInputStream())); out = new PrintWriter(s.getOutputStream()); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } @Override public void run() { try { while (true) { String str = in.readLine(); for (int j = 0; j < list.size(); j++) { Server1.Client c = list.get(j); if (c != this) { System.out.println(str); c.send(str+"-|1|2|-"+name); } } if (str.equals("end")) break; } try { s.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } public void send(String str) throws IOException { out.println(str); out.flush(); } } }
客户端设计
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.util.Scanner; public class Client1 { public static String name = null; static Socket socket = null; static BufferedReader in; static PrintWriter out; public static void main(String[] args) { Scanner sc = new Scanner(System.in); System.out.print("输入用户名:>"); name = sc.nextLine(); try { // socket = new Socket("116.62.173.212", 5678); socket = new Socket("127.0.0.1", 5678); System.out.println(socket); System.out.println("已连接服务器>"); out = new PrintWriter(socket.getOutputStream()); in = new BufferedReader(new InputStreamReader(socket.getInputStream())); Thread receive = new Thread(new receiveThread()); receive.start(); out.println(name); out.flush(); String msg; while (true) { // System.out.print("你说:>"); msg = sc.nextLine(); out.println(msg); out.flush(); if (msg.equalsIgnoreCase("end")) break; } } catch (IOException e) { e.printStackTrace(); } } static class receiveThread implements Runnable{ @Override public void run() { try { while (socket!=null) { String str = in.readLine(); String message = str.split("-\\|1\\|2\\|-")[0]; String name = str.split("-\\|1\\|2\\|-")[1]; System.out.println(name + ":>" + message); } }catch(Exception e) { e.printStackTrace(); } } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。