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();
- }
- }
- }
- }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。
原文链接:https://blog.csdn.net/qq_42843894/article/details/114793283