*/
private Socket netClient;
/**
* 在线用户列表 */
private Vector
/** * 聊天信息 */
private Vector
/**
* 从客户到服务器 输入流 */
private ObjectInputStream fromClient;
/**
* 传到客户端 打印流 */
private PrintStream toClient;
/**
* 注册用户列表
*/
private static Vector vList = new Vector(); /** * 临时对象 */
private Object obj;
/**
* 服务器日志窗体 */
private ServerFrame sFrame;
@SuppressWarnings(\) /**
* 创建与客户端通讯 */
public Connection(ServerFrame frame, Socket client, Vector u, Vector c) {
netClient = client; userOnline = u; userChat = c; sFrame = frame; try {
// 发生双向通信
// 检索客户输入 fromClient = new
ObjectInputStream(netClient.getInputStream());
/**
* 处理与客户端的通讯线程 */
public void run() {
try {// obj是Object类的对象
obj = (Object) fromClient.readObject();
if (obj.getClass().getName().equals(\)) {
serverLogin();
}
// 服务器写到客户
toClient = new PrintStream(netClient.getOutputStream());
} catch (IOException e) { }
this.start();
try {
netClient.close();
} catch (IOException e1) { }
System.out.println(\不能建立流\ + e1); return;
//
{
}
serverLoginDB();
if (obj.getClass().getName().equals(\))
//
serverRegiste(); serverRegisteDB();
}
if (obj.getClass().getName().equals(\)) { }
if (obj.getClass().getName().equals(\)) { }
if (obj.getClass().getName().equals(\)) { }
serverExit(); serverChat(); serverMessage();
} catch (IOException e) {
System.out.println(e);
} catch (ClassNotFoundException e1) {
System.out.println(\读对象发生错误！\ + e1);
} finally {
try {
netClient.close();
} catch (IOException e) {
}
}
}
System.out.println(e);
/** * * 登录处理 */
@SuppressWarnings(\) public void serverLogin() {
try {
Customer clientMessage2 = (Customer) obj;
// 读文件
FileInputStream file3 = new FileInputStream(\); ObjectInputStream objInput1 = new
ObjectInputStream(file3);
int find = 0; // 查找判断标志 // System.out.println(find);
for (int i = 0; i < vList.size(); i++) {
Register_Customer reg = (Register_Customer)
vList = (Vector) objInput1.readObject(); vList.elementAt(i);