【正文】 } User(){ try{ (ver)。 } public String getIp() { return ip。 } public String getName() { return name。 public User(String name, String ip) { = name。 public class User { private String name。 } } } } } 四、數(shù)據(jù)庫直連和文件線程 數(shù)據(jù)庫直連核心代碼： package ceshi。 i) { Java語言程序設(shè)計(jì)（報(bào)告） 41 (i).getWriter().println(message)。 if ((ALL)) {// 群發(fā) for (int i = () 1。 message = source + 說： + content。 String owner = ()。 } } } public void dispatcherMessage(String message) { StringTokenizer stringTokenizer = new StringTokenizer(message, )。 } } } else { dispatcherMessage(message)。// 刪除此 Java語言程序設(shè)計(jì)（報(bào)告） 40 用戶的服務(wù)線程 ()。 i) { if ((i).getUser() == user) { ClientThread temp = (i)。// 更新在線列表 // 刪除此條客戶端服務(wù)線程 for (int i = () 1。 (i).getWriter().flush()。 i = 0。 ()。 // 斷開連接釋放資源 ()。 while (true) { try { message = ()。 } } public void run() {// 不斷接收 客戶端的消息，進(jìn)行處理。 (i).getWriter().flush()。 i = 0。 ()。 i) { temp += ((i).getUser().getName() + / + clients .get(i).getUser().getIp()) + 。 for (int i = () 1。 ()。 user = new User((), ())。 // 接收客戶端的基本用戶信息 String inf = ()。 reader = new BufferedReader(new InputStreamReader(socket .getInputStream()))。 } public User getUser() { return user。 public BufferedReader getReader() { return reader。 private PrintWriter writer。 } } Java語言程序設(shè)計(jì)（報(bào)告） 36 } } class ClientThread extends Thread { private Socket socket。// 更新在線列表 (().getName() + ().getIp() + 上線 !\n)。 //} (client)。// 開啟對此客戶端服務(wù)的線程 new sc(socket2).start()。 } ClientThread client = new ClientThread(socket)。 Java語言程序設(shè)計(jì)（報(bào)告） 35 ()。 // 釋放資源 ()。 // 反饋連接成功信息 (MAX服務(wù)器：對不起， + () + () + ，服務(wù)器在線人數(shù)已達(dá) 上限，請稍后嘗試連接！ )。 StringTokenizer st = new StringTokenizer(inf, )。 PrintWriter w = new PrintWriter(socket .getOutputStream())。 Socket socket2=()。 = max。 private int max。 } } public static void main(String args[]){ new fwq()。 } catch (IOException e) { ()。 } if (serverSocket != null) { ()。 (i).()。// 停止此條為客戶端服務(wù)的線程 (i).()。 (i).getWriter().flush()。 i = 0。 } } SuppressWarnings(deprecation) public void closeServer() { try { if (serverThread != null) ()。 isStart = false。 throw new BindException(端口號(hào)已被占用，請換一個(gè)！ )。 isStart = true。 serverThread = new ServerThread(serverSocket, 4)。 } public void serverStart(int port) throws { try { clients = new ArrayListClientThread()。 } catch (Exception exc) { (null, 停止服務(wù)器發(fā)生異常！ , 錯(cuò)誤 , )。 (服務(wù)器成功停止 !\n)。 (false)。 Java語言程序設(shè)計(jì)（報(bào)告） 31 (true)。 return。 } } })。 (true)。 (false)。 (null, 服務(wù)器成功啟動(dòng) !)。 } serverStart(port)。 } catch (Exception e1) { throw new Exception(端口號(hào)為正整數(shù)！ )。 int port。 return。 (jl2)。 (40,10,110,20)。 //(jb3)。 (jb1)。 (280,20,80,50)。 (jl3)。 (10)。 (40,40,110,20)。 (10,40,75,15)。 //(js4)。 (20,375,300,30)。 (10,85,370,270)。 (false)。 setTitle(聊天室服務(wù)端 )。 setLayout(null)。 private Container a = getContentPane()。 //static JButton jb3=new JButton(傳文件 )。 final JButton jb1=new JButton(啟動(dòng) )。 JLabel jl3=new JLabel(聊天 窗口 )。 JLabel jl1=new JLabel(端口 )。 JTextArea jt3=new JTextArea(1,1)。 JTextField jt1=new JTextField()。 private ServerThread serverThread。 import 。 import 。 import 。 import .*。 import .*。 Java語言程序設(shè)計(jì)（報(bào)告） 26 圖 35 服務(wù)端效果圖 主要代碼如下： package ceshi。// 未連接上 return false。 } catch (Exception e) { (與端口號(hào)為： + port + IP 地址為： + hostIp + 的服務(wù)器連接失敗 ! + \n)。 isConnected = true。 new wjsc(socket2).start()。 // 開啟接收消息的線程 messageThread = ne