[Java] java基于C/S模式实现聊天程序（服务器）

package server;
 
import java.awt.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.event.*;
 
import javax.swing.*;
 
public class server extends jframe {
 
 jtextarea textshow;
 jbutton start;
 vector socketsss = new vector();//这里用到了变长对象数组，用来存储来自客户端的socket对象
 serversocket server = null;
 socket clients;
 
 server() { // 服务器的构造函数，并且初始化
 init();
 setvisible(true);
 setdefaultcloseoperation(jframe.do_nothing_on_close);
 setbounds(450, 150, 340, 455);
 settitle("好好学习天天向上聊天室服务器");
 setresizable(false);
 }
 
 void init() { // 设置布局和事件监视器
 setlayout(new flowlayout());
 getcontentpane().setbackground(new color(20, 85, 237));
 textshow = new jtextarea(21, 29);
 textshow.setbackground(new color(45, 210, 209));
 start = new jbutton("     启动服务器     ");
 start.setbackground(new color(236, 134, 21));
 add(start);
 add(new jscrollpane(textshow));
 textshow.seteditable(false);
 start.addactionlistener(new actionlistener() {
  public void actionperformed(actionevent e) {  //在这里启动监听的线程
  listen listen = new listen();
  thread go = new thread(listen);
  go.start();
  }
 });
 
 addwindowlistener(new windowadapter() { // 响应关闭按钮功能
  public void windowclosing(windowevent e) {
  int option = joptionpane
   .showconfirmdialog(null, "亲爱的你真的要离开聊天室么？",
  " 好好学习天天向上聊天室", joptionpane.yes_no_option,
  joptionpane.question_message);
  if (option == joptionpane.yes_option)
   system.exit(0);
 
  }
 });
 
 } // init()结束
 
 class serverthread extends thread { // 服务器消息处理的线程
 socket socket;
 dataoutputstream out = null;
 datainputstream in = null;
 string s = null;
 vector sockets = new vector();
 int j = 0;
 
 serverthread(socket t, vector socketss) {
  socket = t;
  sockets = socketss;
  try { 
  in = new datainputstream(socket.getinputstream());
  } catch (ioexception e) {
  }
 }
 
 public void run() {
  while (true) {
  try {
   string r = in.readutf();// 堵塞状态，除非读取到信息
   for (int j = 0; j < sockets.size(); j++) {
   out = new dataoutputstream(
  ((socket) sockets.get(j)).getoutputstream()); // 对于每个数组内的socket对象都建立输出流
   out.writeutf(r);
   }
  } catch (ioexception e) {
   textshow.append("有一个逗比离开了\n");
   return;
  }
  }
 }
 }
 
 class listen implements runnable { // 服务器监听线程
 serversocket server;
 socket clients;
 
 public void run() {
  while (true) {
  try {
   server = new serversocket(8888);
   textshow.append(new java.text.simpledateformat(
  "yy-mm-dd hh:mm:ss").format(new date())
  + "服务器已开启\n");
  } catch (ioexception e1) {
   textshow.append("正在监听\n"); // serversocket对象不能重复创建
  }
  try {
   textshow.append(new java.text.simpledateformat(
  "yy-mm-dd hh:mm:ss").format(new date())
  + " 等待用户连接......\n");
 
   clients = server.accept();
   socketsss.add(clients);
   serverthread handlers = new serverthread(clients, socketsss);
   handlers.start(); // 为每个用户创建单独的消息处理线程
   textshow.append(new java.text.simpledateformat(
  "yy-mm-dd hh:mm:ss").format(new date())
  + "有用户连接,用户的地址:" + clients.getinetaddress() + "\n");
  } catch (ioexception e1) {
   textshow.append(new java.text.simpledateformat(
  "yy-mm-dd hh:mm:ss").format(new date())
  + "正在等待逗比来临......\n");
  }
  }
 }
 }
 
 public static void main(string args[]) {
 server server = new server();
 }
}