在线群聊系统
1，团队课程设计博客链接
http://www.cnblogs.com/slickghost/p/7018105.html
个人负责模块或任务说明
负责模块：总体设计及主要聊天功能实现
2，自己的代码提交记录截图
3，自己负责模块或任务详细说明
服务器和客户端之间的各种请求，我通过自定义的标志来确认，如验证用户，首先，客户端会先发送”login”告诉服务器，这是一个登入请求。服务器接收到这个请求，就会等待接收一个User对象（通过序列化传输，把信息都放在这个对象内，更方便）提取用户名密码进行验证，通过数据库验证返回结果，再把结果告诉客户端，客户端收到true后，便告知用户登入成功。
//验证用户
public boolean sendUserToServerLogin(User user) throws IOException, ClassNotFoundException{
objectout.writeObject("login");
objectout.flush();
objectout.writeObject(user);
objectout.flush();
//输入对象, 一定要flush（）
//objectout.close();
//验证结果
while(true){
String msg = objectin.readObject().toString();
if(msg.equals("true")){
return true;
}
else {
socket.close();
return false;
}
}
}
//1.登入请求，接收到一个User对象，验证其用户名和密码
if(mgs.equals("login")){
if((obj = objectin.readObject()) !=null){
User user = (User)obj;
if(serverUserDaoJDBCImpl.checkUser(user)){
ServerRunLog.log.info("User("+
user.getNumber()+") Login." );
objectout.writeObject("true");
}
else{
objectout.writeObject("false");
}
}
}
public boolean checkUser(User user) {
if(loadUser(user.getNumber()).getNumber() == user.getNumber() &&
loadUser(user.getNumber()).getPassword().equals(user.getPassword()))
return true;
return false;
}
public User loadUser(int number) {
Connection conn = null;
PreparedStatement pstat = null;
String sql = "select * from userData where number = ?";
ResultSet rs = null;
try {
conn = JDBCUtil.getConnection();
pstat = conn.prepareStatement(sql);
pstat.setInt(1, number);
rs = pstat.executeQuery();
while(rs.next()){
String netName = rs.getString("netName");
String password = rs.getString("password");
String sign=rs.getString("sign");
String telephone=rs.getString("telephone");
int isVip = rs.getInt("isVip");
User user = new User(number,password,netName,sign,telephone,isVip);
return user;
}
}catch (SQLException sqle) {
sqle.printStackTrace();
}catch(Exception e){
e.printStackTrace();
}finally{
JDBCUtil.realeaseAll(null,pstat, conn);
}
return new User();
}
其他请求类似。
接下来看一下主要的聊天转发功能：某个加入群聊，服务器将其加入线程列表，其发送消息时，服务器会将消息转发到线程列表内的所有用户。
if(e.getSource()==chatJFrame.getSendButton()){
String msg = chatJFrame.getEditorTextArea1().getText();
try {
objectout.writeObject("message");
objectout.flush();
objectout.writeObject(msg);
objectout.flush();
//System.out.println(msg);
chatJFrame.getEditorTextArea1().setText("");
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
//6.普通信息
if(mgs.equals("message")){
String groupMsg = user.getNetName() + ": " + objectin.readObject().toString();
for (int i = 0; i < mainThread.onLineUserList.size(); i++) {
mainThread.onLineUserList.get(i).objectout.writeObject("groupMessage");
mainThread.onLineUserList.get(i).objectout.flush();
mainThread.onLineUserList.get(i).objectout.writeObject(groupMsg + "
");
mainThread.onLineUserList.get(i).objectout.flush();
}