本科毕业论文-基于JAVA的聊天系统的设计与实现(4)

3 .2 聊天系统的设计步骤及功能模块划分

聊天系统工作原理图

本科毕业论文-基于JAVA的聊天系统的设计与实现

3.3 聊天系统各功能模块

（1）服务器程序模块

服务器与客户间通过套接口Socket(TCP)连接。在java中使用套接口相当简单，Java API为处理套接口的通信提供了一个类.Socket，使得编写网络应用程序相对容易。服务器采用多线程以满足多用户的请求，并通过创建一个ServerSocket对象来监听来自客户的连接请求，默认端口为9527，然后无限循环调用accept()方法接受客户程序的连接。

服务器线程源码： package qq.server;

import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import .Socket; import java.util.*;

import qq.dao.hibernate.IServiceDao; import qq.entity.*;

public class ServerController {

private User user;

本科毕业论文-基于JAVA的聊天系统的设计与实现

private Socket s; private IServiceDao dao; private ObjectInputStream ois; private ObjectOutputStream oos; private OnlineUser onlineUser;

public ServerController(Socket s) { }

public void handle() throws Exception {

ois=new ObjectInputStream(s.getInputStream()); oos=new ObjectOutputStream(s.getOutputStream()); onlineUser=new OnlineUser(ois,oos); while(true){

Request req=(Request)ois.readObject(); ois.read();

RequestType type=req.getType(); if(type.equals(RequestType.exit)){

exitHandle(); break;

loginHandle(req); registerHandle(); offlineHandle(); break;

changeInformationHandle(); modifypasswdHandle(req);

super();

dao=erDao; this.s = s;

}else if(type.equals(RequestType.login)){ }else if(type.equals(RequestType.register)){ }else if(type.equals(RequestType.offline)){

}else if(type.equals(RequestType.changeInformation)){ }else if(type.equals(RequestType.modifypasswd)){

本科毕业论文-基于JAVA的聊天系统的设计与实现

}

}

}else if(type.equals(RequestType.sendMessage)){ }

sendMessageHandle(req); receiveFileHandle(req); sendFileHandle(req);

}else if(type.equals(RequestType.receiveFile)){ }else if(type.equals(RequestType.sendFile)){

private void modifypasswdHandle(Request req) { }

private void changeInformationHandle() {

try {

User user=(User)ois.readObject(); Long id=Long.parseLong(req.getData("id")); String oldpwd=req.getData("oldpwd"); String newpwd=req.getData("newpwd");

Response res=new Response(RequestType.modifypasswd); try { }

dao.updatePwd(id, oldpwd, newpwd); res.setData(1); try { } try { }

oos.writeObject(res); e1.printStackTrace(); } catch (IOException e1) {

oos.writeObject(res); e.printStackTrace(); } catch (IOException e) {

} catch (RuntimeException e) {