广州大学网络编程实验二代码（UDP编程）

package com.jwt.client; import com.jwt.entity.Message; import com.jwt.entity.MessageType; import com.jwt.entity.User; import com.jwt.view.ChatRoom; import com.jwt.view.ManageChatRoom; import com.jwt.view.OnlineView; import javax.swing.*; import java.io.*; import java.net.DatagramSocket; import java.net.InetAddress; import java.util.List; import java.util.concurrent.ConcurrentHashMap; /** * * @author：gd_jwt * 处理Message类型消息的线程 * */ public class AnswerMessageThread extends Thread{ private static int answerCount=0;//已读下标 private static DatagramSocket datagramSocket=null; private User user = null;//本客户端用户 private static boolean b=true;//标记，用于退出线程 public AnswerMessageThread(DatagramSocket datagramSocket,User user) { this.datagramSocket = datagramSocket; this.user=user; System.out.println("已开启消息处理线程（端口为："+datagramSocket.getLocalPort()+"）"); } @Override public void run() { while(b){ try { //获取接收Message的集合 List<Message> messageList = ReceiveMessageThread.getMessageList(); //当已读下标小于集合的元素个数时，表明有新的消息未处理 if(answerCount<messageList.size()){ //有新的消息时才调用 doAnswer(messageList); } sleep(20);//每隔20ms读取一次消息集合 } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } } } /* * 处理消息的方法，根据消息的不同类型进行不同的响应 * */ public void doAnswer(List<Message> messageList) throws IOException { //本客户端用户Id String uId = user.getUserId(); //回复给客户端的消息 Message retMes=new Message(); int temp=0; for(temp=answerCount;temp<messageList.size();temp++){ Message message = messageList.get(temp); User sender = null; String senderId = ""; //规定除了服务器发送的Message消息，其他客户端发送的和服务器转发的群聊消息都要设置sender sender = message.getSender(); if(sender!=null){ senderId = sender.getUserId(); } //根据消息的不同类型进行不同的响应 switch (message.getMesType()){ /*返回在线用户*/ case MessageType.MESSAGE_RET_ONLINE_USER:{ //取出message里的在线用户集合 List<User> onlineUsers = message.getOnlines(); //初始化在线用户界面 OnlineView onlineUserView = new OnlineView(datagramSocket, onlineUsers.size()); onlineUserView.setTitle("在线用户列表"); for (User onlineUser : onlineUsers) { //在线用户Id JLabel jId = onlineUserView.initJId(onlineUser.getUserId()); //添加好友按钮 JButton jAddFri = onlineUserView.initAddFri(user, onlineUser.getUserId()); onlineUserView.add(jId); onlineUserView.add(jAddFri); } //显示在线用户界面 onlineUserView.setVisible(true); break; } /*返回在线好友*/ case MessageType.MESSAGE_RET_ONLINE_FRIEND: { //取出message里的在线好友集合 List<User> onlineFriends = message.getOnlines(); //初始化在线好友界面 OnlineView onlineUserView = new OnlineView(datagramSocket, onlineFriends.size()); onlineUserView.setTitle("在线好友列表"); for (User friend : onlineFriends) { //调用方法检查该好友对应的聊天室有没有被创建 ChatRoom chatOne = chatRoomIsInHm(friend); //在线好友Id JLabel jId = onlineUserView.initJId(friend.getUserId()); //好友私聊按钮 JButton jSendMes = onlineUserView.initSendMes(chatOne, uId, friend.getUserId()); //发送文件按钮 JButton jSendFile = onlineUserView.initSendFileMes(chatOne, user, friend); onlineUserView.add(jId); onlineUserView.add(jSendMes); onlineUserView.add(jSendFile); } //显示在线好友界面 onlineUserView.setVisible(true); break; } /*添加好友成功提示*/ case MessageType.MESSAGE_ADD_ONLINE_FRIEND: { //添加好友成功提示 JOptionPane.showMessageDialog(null, "添加成功！", "提示窗口", JOptionPane.INFORMATION_MESSAGE); break; } /*收到普通文本消息*/ case MessageType.MESSAGE_COMM_MES: { //取出发送者的聊天室 ChatRoom chatOne = chatRoomIsInHm(sender); //取出消息的文本内容，写入聊天框中 chatOne.getTextArea().append(senderId+": "+message.getContent()+"\r\n"); //显示聊天界面 chatOne.setVisible(true); ChatService.sendTextMes(datagramSocket,retMes,InetAddress.getByName(sender.getUserIp()),sender.getPort()); break; } /*第一次加入聊天室成功提醒*/ case MessageType.MESSAGE_ADD_TO_ALL:{ //服务器发送提醒确认后，客户端才创建群聊聊天室 ChatRoom chatRoom = new ChatRoom(datagramSocket); //设置按钮为群发消息 chatRoom.chatMoreView(); //指明用户为自己，即发送者为自己 chatRoom.setUser(user); chatRoom.setTitle("多人聊天室（"+user.getUserId()+"）"); //规定设置聊天室名称为“ALL"，代表群聊 ManageChatRoom.addRoom("ALL",chatRoom); //显示聊天室 chatRoom.setVisible(true); //第一次加入聊天室时提示 JOptionPane.showMessageDialog(null, "加入聊天室成功！", "提示窗口", JOptionPane.INFORMATION_MESSAGE); break; } /*收到群聊消息*/ case MessageType.MESSAGE_TO_ALL_MES: { //取出群聊聊天室 ChatRoom chatAll = ManageChatRoom.friIdgetChatRoom("ALL"); //取出消息的文本内容，写入聊天框中 chatAll.getTextArea().append(senderId+": "+message.getContent()+"\r\n"); //显示聊天界面 chatAll.setVisible(true); break; } /* * 收到发送文件请求。如果同意接收，规定接收方要回复新的接收端口 * 同意接收后开启新的线程，在新的端口进行接收，避免冲突