Java局域网内如何搭建聊天服务器？

本文共计259个文字，预计阅读时间需要2分钟。

javaimport java.io.*;import java.net.*;import java.util.*;

public class Servers { ServerSocket serverSocket; ArrayList ins; ArrayList outs; LinkedList msgList;

public Servers() { serverSocket=new ServerSocket(1234); ins=new ArrayList(); outs=new ArrayList(); msgList=new LinkedList(); }}

gistfile1.txt

import java.io.*; import java.net.*; import java.util.*; public class Severs { ServerSocket severSocket; ArrayList ins = new ArrayList (); ArrayList

outs = new ArrayList

(); LinkedList msgList = new LinkedList (); public Severs(){ try{ severSocket = new ServerSocket (8888); }catch(IOException e){ e.printStackTrace(); } //创建AcceptSocketThread线程，并启动 new AcceptSocketThread().start(); //创建SendMsgToClient线程，并启动 new SendMsgToClient().start(); System.out.println("Sever Start..."); } //接受客户端套接字线程 class AcceptSocketThread extends Thread { public void run(){ while (this.isAlive()){ try{ //接受套接字 Socket socket = severSocket.accept(); if(socket != null){ BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); ins.add(in); outs.add(new PrintWriter (socket.getOutputStream())); } }catch(IOException e){ e.printStackTrace(); } } } } //接收客户的聊天信息的线程 class GetMsgFromClient extends Thread{ BufferedReader in; public GetMsgFromClient (BufferedReader in){ this.in = in; } public void run(){ while(this.isAlive()) { try{ String strMsg = in.readLine(); if(strMsg != null){ msgList.addFirst(strMsg); } }catch(Exception e){ e.printStackTrace(); } } } } //给所有客户发送聊天信息的线程 class SendMsgToClient extends Thread { public void run(){ while( this.isAlive()){ try{ if(!msgList.isEmpty()){ String s = msgList.removeLast(); for(int i=0; i