《计算机网络通信》课程设计报告(7)

附 录

}

public void sendStopToAll()//向所有在线用户发送服务关闭消息 {

int count =userInfoList.getCount(); int i=0; while (i

Node node=userInfoList.find(i); if(node==null) { } try

－ 18 －

i++; continue;

int i=0; while (i

jbStartServer.setEnabled(true); jbStopServer.setEnabled(false); systemMsg.setEnabled(false);

Node node=userInfoList.find(i);

node.input.close(); node.output.close(); node.socket.close(); i++;

combobox.removeAllItems(); combobox.addItem(\所有人\}

catch(Exception e) { }

附 录

}

public void sendSystemMessage()//实现发送系统消息功能 { }

－ 19 －

String toSomebody=combobox.getSelectedItem().toString(); String message=systemMsg.getText(); if (toSomebody.equalsIgnoreCase(\所有人\{ } else { }

Node node=userInfoList.find(toSomebody); try { }

catch (Exception e) { }

node.output.writeObject(\系统信息\node.output.flush();

node.output.writeObject(message+\node.output.flush();

sendMsgToAll(message+\ }

{ }

catch(Exception e) { } i++;

node.output.writeObject(\服务关闭\node.output.flush();

附 录

public void sendMsgToAll(String msg) { } }

//服务器侦听线程类 import java.awt.*;

－ 20 －

public static void main(String args[]) { }

new ServerFrame();

int count=userInfoList.getCount(); int i=0; while (i

Node node=userInfoList.find(i); if (node==null) { } try { }

catch (Exception e) { } i++;

node.output.writeObject(\系统信息\node.output.flush();

node.output.writeObject(msg); node.output.flush(); i++; continue;

附 录

import java.awt.event.*; import javax.swing.*; import javax.swing.event.*; import java.io.*; import java.net.*;

public class ServerListenThread extends Thread {

ServerSocket server;

JComboBox combobox; JTextArea textarea; JTextField textfield; UserInfoList userInfoList;

Node client;

ServerReceiveThread recvThread;

public boolean isStop;

public ServerListenThread( { }

－ 21 －

this.server=server; this.combobox=combobox; this.textarea=textarea; this.textfield=textfield; this.userInfoList=userInfoList; isStop=false;

ServerSocket server, JComboBox combobox, JTextArea textarea, JTextField textfield, UserInfoList userInfoList )

附 录

public void run() {

while (!isStop&&!server.isClosed()) {

try {

client=new Node();

client.socket=server.accept(); client.output=new

ObjectOutputStream(client.socket.getOutputStream());

client.output.flush(); client.input=new

ObjectInputStream(client.socket.getInputStream());

}

}

}

}

catch(Exception e) { }

client.username=(String)client.input.readObject();

combobox.addItem(client.username); userInfoList.add(client);

textarea.append(\上线\

textfield.setText(\在线用户\人\\n\recvThread=new ServerReceiveThread(

textarea, textfield, combobox, client, userInfoList);

recvThread.start();

//服务器接收线程类

－ 22 －