socket聊天室实现-群聊，私聊，好友列表，完整版

￡神魔★判官ぃ 2022-12-01 14:16 277阅读 0赞

效果图

登录。好友上线，下线均提示。
登录
点击好友列表所有人，发送消息，既为群聊
群聊功能
点击好友列表，好友名字，既为选中此好友进行私聊
私聊功能

服务器端代码

ChatRoomServer

  1. package sram.server;
  2. import java.io.IOException;
  3. import java.net.ServerSocket;
  4. import java.net.Socket;
  5. import java.util.HashMap;
  6. import sram.thread.ChatRoomServerReaderThread;
  7. import sram.user.User;
  9. public class ChatRoomServer {
  10.     private ServerSocket ss;
  11.     public static HashMap<User, Socket> online = new HashMap<User, Socket>(); 
  12.     public ChatRoomServer(){
  13.         try {
  14.             ss = new ServerSocket(6666);
  15.             System.out.println("服务器已经开启,等待客户端...");
  16.             while(true){
  17.                 Socket s = ss.accept();
  18.                 new Thread(new ChatRoomServerReaderThread(s)).start();
  19.             }            
  20.         } catch (IOException e) {
  21.             // TODO Auto-generated catch block
  22.             e.printStackTrace();
  23.         }        
  24.     }
  25.     public static void main(String[] args) {
  26.         new ChatRoomServer();
  27.     }    
  28. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28

ChatRoomServerReaderThread

  1. package sram.thread;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintWriter;
  7. import java.net.Socket;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10. import java.util.Set;
  12. import sram.server.ChatRoomServer;
  13. import sram.user.Message;
  14. import sram.user.User;
  15. import sram.util.SendMessageUtil;
  17. import net.sf.json.JSONArray;
  18. import net.sf.json.JSONObject;
  20. public class ChatRoomServerReaderThread implements Runnable {
  21.     private Socket s;
  22.     private BufferedReader br;
  23.     private PrintWriter pw;
  24.     private Message message;
  26.     public ChatRoomServerReaderThread(Socket s) throws IOException {
  27.         this.s = s;
  28.         br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  29.         pw = new PrintWriter(s.getOutputStream(),true);
  30.     }
  33.     @Override
  34.     public void run() {
  35.         String str = null;
  36.         try {
  37.             while((str = br.readLine())!=null){
  38.                 message = new Message(); //返回的消息。
  39.                 System.out.println("发过来的消息是："+str);
  40.                 Message msg = 
  41.                     (Message) JSONObject.toBean
  42.                         (JSONObject.fromObject(str), Message.class);
  43.                 switch (msg.getType()) {
  44.                 case 1: //处理登录消息。
  45.                     User loginUser = msg.getFromUser();
  46.                     if(ChatRoomServer.online.containsKey(loginUser)){
  47.                         //用户名已经存在，不能登录
  48.                         message.setType(11);
  49.                         pw.println(JSONObject.fromObject(message).toString());
  50.                     }else{
  51.                         //用户名未存在，可以登录，返回可以登录的消息
  52.                         //获取所有用户
  53.                         List<User> users = new ArrayList<User>(ChatRoomServer.online.keySet());
  54.                         //List转化为JSON字符串
  55.                         message.setMessage(JSONArray.fromObject(users).toString());
  56.                         message.setType(10);
  57.                         ChatRoomServer.online.put(loginUser, s);
  58.                         pw.println(JSONObject.fromObject(message).toString());
  60.                         //用户登录成功后，系统发送系统消息给每个用户，告诉所有用户 XXX上线了。
  61.                         message.setType(4);
  62.                         message.setFromUser(loginUser);
  63.                         //调用群发方法，群发消息给所有用户。
  64.                         SendMessageUtil.sendMessage(ChatRoomServer.online, message);
  65.                     }
  66.                     break;
  67.                 case 3:
  68.                     User out = msg.getFromUser();
  69.                     ChatRoomServer.online.remove(out);
  70.                     message.setType(5); 
  71.                     message.setFromUser(out);
  72.                     SendMessageUtil.sendMessage(ChatRoomServer.online, message);
  73.                     break;
  74.                 case 20: //处理私聊消息
  75.                     User toUser = msg.getToUser();
  76.                     Socket s = ChatRoomServer.online.get(toUser);
  77.                     PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
  78.                     msg.setType(22);
  79.                     pw.println(JSONObject.fromObject(msg).toString());
  80.                     break;
  81.                 case 21: //处理群聊消息
  82.                     msg.setType(23);
  83.                     SendMessageUtil.sendMessage(ChatRoomServer.online,msg);
  84.                     break;
  85.                 }
  86.                 if(msg.getType()==3){
  87.                     break;
  88.                 }
  89.             }            
  90.         } catch (IOException e) {
  91.             // TODO Auto-generated catch block
  92.             e.printStackTrace();
  93.         }
  94.     }    
  95. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95

Message

  1. package sram.user;
  3. //用来描述发送消息的类。 1登陆 2聊天 3退出  4系统消息等
  4. public class Message {
  5.     private String message; //发送消息内容
  6.     private int type; //发送消息类型
  7.     private User fromUser; //来源自谁的消息
  8.     private User toUser; //发送给谁
  10.     public String getMessage() {
  11.         return message;
  12.     }
  13.     public void setMessage(String message) {
  14.         this.message = message;
  15.     }
  16.     public int getType() {
  17.         return type;
  18.     }
  19.     public void setType(int type) {
  20.         this.type = type;
  21.     }
  22.     public User getFromUser() {
  23.         return fromUser;
  24.     }
  25.     public void setFromUser(User fromUser) {
  26.         this.fromUser = fromUser;
  27.     }
  28.     public User getToUser() {
  29.         return toUser;
  30.     }
  31.     public void setToUser(User toUser) {
  32.         this.toUser = toUser;
  33.     }    
  34. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34

User

  1. package sram.user;
  2. //用户实体类。登陆成功后，可以被保存在服务器端。
  3. public class User {
  4.     private String username; //用户名，唯一的标识
  5.     private String nickname;//用户自定义的网络名称
  8.     public String getUsername() {
  9.         return username;
  10.     }
  11.     public void setUsername(String username) {
  12.         this.username = username;
  13.     }
  14.     public String getNickname() {
  15.         return nickname;
  16.     }
  17.     public void setNickname(String nickname) {
  18.         this.nickname = nickname;
  19.     }
  20.     public User(String username, String nickname) {
  21.         this.username = username;
  22.         this.nickname = nickname;
  23.     }
  24.     public User() {
  25.     }
  26.     @Override
  27.     public int hashCode() {
  28.         // TODO Auto-generated method stub
  29.         return 0;
  30.     }
  31.     @Override
  32.     public boolean equals(Object obj) {
  33.         User user = (User)obj;
  34.         return this.username.equals(user.username);
  35.     }
  36. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36

SendMessageUtil

  1. package sram.util;
  3. import java.io.IOException;
  4. import java.io.PrintWriter;
  5. import java.net.Socket;
  6. import java.util.Map;
  7. import java.util.Set;
  9. import net.sf.json.JSONObject;
  11. import sram.user.Message;
  12. import sram.user.User;
  14. public class SendMessageUtil {
  15.     //群发的方法
  16.     public static void sendMessage(Map<User, Socket> online,Message message) throws IOException{
  17.         Set<User> users = online.keySet();
  18.         for(User user :users){
  19.             Socket s = online.get(user);
  20.             PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
  21.             pw.println(JSONObject.fromObject(message).toString());
  22.         }
  23.     }
  24. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24

客户端代码

ClientFrame

  1. package sram.frame;
  3. import java.awt.BorderLayout;
  4. import java.awt.ScrollPane;
  5. import java.awt.event.ActionEvent;
  6. import java.awt.event.ActionListener;
  7. import java.awt.event.MouseAdapter;
  8. import java.awt.event.MouseEvent;
  9. import java.awt.event.WindowAdapter;
  10. import java.awt.event.WindowEvent;
  11. import java.io.IOException;
  12. import java.io.PrintWriter;
  13. import java.net.Socket;
  14. import java.text.SimpleDateFormat;
  15. import java.util.Date;
  16. import java.util.List;
  18. import javax.swing.JButton;
  19. import javax.swing.JFrame;
  20. import javax.swing.JLabel;
  21. import javax.swing.JOptionPane;
  22. import javax.swing.JPanel;
  23. import javax.swing.JScrollBar;
  24. import javax.swing.JScrollPane;
  25. import javax.swing.JTextArea;
  26. import javax.swing.JTextField;
  27. import javax.swing.JTree;
  28. import javax.swing.border.Border;
  29. import javax.swing.border.TitledBorder;
  30. import javax.swing.tree.DefaultMutableTreeNode;
  31. import javax.swing.tree.DefaultTreeModel;
  33. import net.sf.json.JSONObject;
  35. import sram.user.Message;
  36. import sram.user.User;
  38. public class ClientFrame {
  39.     private JFrame frame; //主窗口
  40.     private JTextArea area; //显示消息的文本域
  41.     private JTextField text; //输入消息的文本框
  42.     private JButton btnSend; //发送消息的按钮
  43.     private JPanel p1,p2,p3; //布局使用的面板
  44.     private TitledBorder b1,b2,b3;
  45.     //好友列表使用JTree显示
  46.     private JTree tree;
  47.     private DefaultMutableTreeNode root;// 根节点
  48.     private DefaultTreeModel model; //树模型
  50.     private User user;
  51.     private Socket socket;
  52.     private PrintWriter pw;
  53.     private User toUser = new User("All","所有人");
  54.     private List<User> friends;
  58.     public DefaultMutableTreeNode getRoot() {
  59.         return root;
  60.     }
  61.     public void setRoot(DefaultMutableTreeNode root) {
  62.         this.root = root;
  63.     }
  64.     public DefaultTreeModel getModel() {
  65.         return model;
  66.     }
  67.     public void setModel(DefaultTreeModel model) {
  68.         this.model = model;
  69.     }
  70.     public User getUser() {
  71.         return user;
  72.     }
  73.     public void setUser(User user) {
  74.         this.user = user;
  75.     }
  76.     public JTextArea getArea() {
  77.         return area;
  78.     }
  79.     public void setArea(JTextArea area) {
  80.         this.area = area;
  81.     }
  82.     public ClientFrame(User user,Socket socket,List<User> friends){
  83.         this.user = user;//******************************************************
  84.         this.socket = socket;//**************************************************
  85.         this.friends = friends;//************************************************
  86.         //调用init()方法初始化界面
  87.         init();
  88.         listener();
  89.     }
  90.     //初始化方法显示界面
  91.     public void init(){
  92.         //初始化对象**********************************************
  93.         try {
  94.             pw = new PrintWriter(socket.getOutputStream(),true);
  95.         } catch (IOException e) {
  96.             e.printStackTrace();
  97.         }
  98.         frame = new JFrame("当前用户：["+user.getNickname()+"("+user.getUsername()+")"+"]");
  99.         area = new JTextArea();
  100.         area.setEditable(false);
  101.         area.setLineWrap(true);
  102.         text = new JTextField(20);
  103.         root = new DefaultMutableTreeNode("我的好友");
  104.         model = new DefaultTreeModel(root);
  105.         model.insertNodeInto(new DefaultMutableTreeNode(new User("All", "所有人")), root,root.getChildCount());
  106.         //************************************************************************************
  107.         if(friends!=null && friends.size()>0){
  108.             for(User userf : friends){
  109.                 model.insertNodeInto(new DefaultMutableTreeNode(userf), root,root.getChildCount());
  110.             }
  111.         }
  112.         //************************************************************************************
  113.         tree = new JTree(model);
  114.         //启用折叠显示
  115.         tree.setShowsRootHandles(true);
  116.         btnSend = new JButton("发送");
  117.         b1 = new TitledBorder("好友列表");
  118.         b2 = new TitledBorder("消息显示");
  119.         b3 = new TitledBorder("发送消息");
  120.         p1 = new JPanel(); //右边的面板,用来显示好友列表
  121.         p2 = new JPanel(); //中间的面板,用来显示JTextArea
  122.         p3 = new JPanel(); //下边的面板,用来显示文本输入框和发送按钮
  123.         p1.setLayout(new BorderLayout());
  124.         p2.setLayout(new BorderLayout());
  125.         p1.setBorder(b1);
  126.         p2.setBorder(b2);
  127.         p3.setBorder(b3);
  128.         p1.add(new JScrollPane(tree));
  129.         p2.add(new JScrollPane(area,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_NEVER),BorderLayout.CENTER);
  130.         p3.add(text);
  131.         p3.add(btnSend);
  132.         p2.add(p3,BorderLayout.SOUTH);
  133.         frame.add(p1,BorderLayout.WEST);
  134.         frame.add(p2,BorderLayout.CENTER);
  135.         frame.setResizable(false);
  136.         frame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
  137.         frame.setSize(500, 450);
  138.         frame.setVisible(true);
  140.     }
  141.     public void listener(){
  142.         frame.addWindowListener(new WindowAdapter() {
  143.             @Override
  144.             public void windowClosing(WindowEvent e) {
  145.                 int i = JOptionPane.showConfirmDialog(null, "您确定要退出聊天室?");
  146.                 if(i == JOptionPane.OK_OPTION){
  147.                     Message message = new Message();
  148.                     message.setType(3); //退出消息
  149.                     message.setFromUser(user);
  150.                     pw.println(JSONObject.fromObject(message).toString());
  151.                     try {
  152.                         Thread.sleep(100);
  153.                         System.exit(0);
  154.                     } catch (InterruptedException e1) {
  155.                         // TODO Auto-generated catch block
  156.                         e1.printStackTrace();
  157.                     }
  158.                 }
  159.             }
  160.         });
  162.         tree.addMouseListener(new MouseAdapter() {
  163.             @Override
  164.             public void mouseClicked(MouseEvent e) {
  165.                 if(tree.getSelectionPath()!=null && tree.getSelectionPath().getParentPath()!=null){
  166.                     //获取点击节点的行数//*********************************************
  167.                     int i = tree.getLeadSelectionRow();
  168.                     DefaultMutableTreeNode node 
  169.                         = (DefaultMutableTreeNode) root.getChildAt(i-1);
  170.                     toUser = (User) node.getUserObject();
  171.                     frame.setTitle("当前用户：["+user.getNickname()
  172.                             +"("+user.getUsername()+")"+"] 和 ["+toUser.getNickname()
  173.                             +"("+toUser.getUsername()+")"+"]的聊天");
  174.                 }
  175.             }
  176.         });
  177.         btnSend.addActionListener(new ActionListener() {
  178.             @Override
  179.             public void actionPerformed(ActionEvent e) {
  180.                 //私聊 群聊
  181.                 Date date = new Date();
  182.                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  183.                 String msg = text.getText();
  184.                 if(msg!=null && !msg.equals("")){
  185.                     Message message = new Message();
  186.                     message.setMessage(msg);
  187.                     message.setFromUser(user);
  188.                     text.setText("");
  189.                     if(toUser!=null){
  190.                         if(toUser.getUsername().equals("All")){
  191.                             message.setType(21);
  192.                             area.append("【群聊】"+user.getNickname()
  193.                                     +"("+user.getUsername()+") "+sdf.format(date)+" 说:");
  194.                             area.append(msg+"\r\n");
  195.                         }else{
  196.                             message.setType(20);
  197.                             area.append("【私聊】"+user.getNickname()
  198.                                     +"("+user.getUsername()+") "+sdf.format(date)+" 说:");
  199.                             area.append(msg+"\r\n");
  200.                         }
  201.                     }
  202.                     message.setToUser(toUser);
  203.                     pw.println(JSONObject.fromObject(message).toString());
  204.                 }
  205.             }
  206.         });
  208.     }
  209.     public static void main(String[] args) {
  210.         //new ClientFrame(new User(),new Socket());
  211.     }    
  212. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
  • 197
  • 198
  • 199
  • 200
  • 201
  • 202
  • 203
  • 204
  • 205
  • 206
  • 207
  • 208
  • 209
  • 210
  • 211
  • 212

LoginFrame

  1. package sram.frame;
  3. import java.awt.Dimension;
  4. import java.awt.GridLayout;
  5. import java.awt.Toolkit;
  6. import java.awt.event.ActionEvent;
  7. import java.awt.event.ActionListener;
  8. import java.io.BufferedReader;
  9. import java.io.IOException;
  10. import java.io.InputStreamReader;
  11. import java.io.PrintWriter;
  12. import java.net.Socket;
  13. import java.net.UnknownHostException;
  14. import java.util.List;
  16. import javax.swing.JButton;
  17. import javax.swing.JFrame;
  18. import javax.swing.JLabel;
  19. import javax.swing.JOptionPane;
  20. import javax.swing.JPanel;
  21. import javax.swing.JTextField;
  23. import net.sf.json.JSONArray;
  24. import net.sf.json.JSONObject;
  26. import sram.thread.ChatRoomClientReaderThread;
  27. import sram.user.Message;
  28. import sram.user.User;
  30. public class LoginFrame {
  31.     private JFrame frame;
  32.     private JLabel usernameLabel;
  33.     private JLabel nicknameLabel;
  34.     private JTextField usernameText;
  35.     private JTextField nicknameText;
  36.     private JButton btnRest;
  37.     private JButton btnLogin;
  38.     private JPanel p1,p2,p3;
  39.     public LoginFrame(){
  40.         init();
  41.         listener();
  42.     }
  43.     public void init(){
  44.         frame = new JFrame();
  45.         usernameLabel = new JLabel("用户名");
  46.         nicknameLabel = new JLabel("昵    称");
  47.         usernameText = new JTextField(10);
  48.         nicknameText = new JTextField(10);
  49.         btnRest = new JButton("重置");
  50.         btnLogin = new JButton("登录");
  51.         p1 = new JPanel();
  52.         p2 = new JPanel();
  53.         p3 = new JPanel();
  54.         frame.setLayout(new GridLayout(3, 1));
  55.         p1.add(usernameLabel);
  56.         p1.add(usernameText);
  57.         p2.add(nicknameLabel);
  58.         p2.add(nicknameText);
  59.         p3.add(btnRest);
  60.         p3.add(btnLogin);
  61.         frame.add(p1);
  62.         frame.add(p2);
  63.         frame.add(p3);
  64.         frame.setResizable(false);
  65.         frame.pack();
  66.         Toolkit t = Toolkit.getDefaultToolkit(); //获取工具包
  67.         Dimension d = t.getScreenSize(); //获取屏幕尺寸
  68.         frame.setLocation(d.width/2-175,d.height/2-40);
  69.         frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  70.         frame.setVisible(true);
  71.     }
  73.     public void listener(){
  74.         btnLogin.addActionListener(new ActionListener() {
  76.             @Override
  77.             public void actionPerformed(ActionEvent e) {
  78.                 String username = usernameText.getText();
  79.                 String nickname = nicknameText.getText();
  80.                 User user = new User(username,nickname);
  81.                 Message msg = new Message();
  82.                 msg.setType(1);
  83.                 msg.setFromUser(user);
  84.                 try {
  85.                     Socket s = new Socket("127.0.0.1",6666);
  86.                     PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
  87.                     pw.println(JSONObject.fromObject(msg).toString());
  89.                     BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  90.                     String message = br.readLine();
  91.                     System.out.println("客户端接受的消息是："+message);
  92.                     Message msgReturn = 
  93.                         (Message) JSONObject.toBean
  94.                             (JSONObject.fromObject(message), Message.class);
  95.                     switch (msgReturn.getType()) {
  96.                     case 10:
  97.                         System.out.println("开启聊天窗口");
  98.                         String usersStr = msgReturn.getMessage();
  99.                         List<User> list = JSONArray.toList(JSONArray.fromObject(usersStr),User.class);
  100.                         ClientFrame f = new ClientFrame(user,s,list);
  101.                         new Thread(new ChatRoomClientReaderThread(s, f)).start();
  102.                         frame.setVisible(false);
  103.                         break;
  104.                     case 11:
  105.                         s.close();
  106.                         JOptionPane.showMessageDialog(null, "用户名已经存在，请重新输入后登录");
  107.                         break;
  108.                     default:
  109.                         break;
  110.                     }
  112.                 } catch (UnknownHostException e1) {
  113.                     // TODO Auto-generated catch block
  114.                     e1.printStackTrace();
  115.                 } catch (IOException e1) {
  116.                     // TODO Auto-generated catch block
  117.                     e1.printStackTrace();
  118.                 }
  119.             }
  120.         });
  121.     }
  123.     public static void main(String[] args) {
  124.         new LoginFrame();
  125.     }
  126. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126

ChatRoomClientReaderThread

  1. package sram.thread;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintWriter;
  7. import java.net.Socket;
  8. import java.text.SimpleDateFormat;
  9. import java.util.Date;
  11. import net.sf.json.JSONObject;
  13. import sram.frame.ClientFrame;
  14. import sram.user.Message;
  15. import sram.user.User;
  16. import sram.util.FriendsTreeFlushUtil;
  18. public class ChatRoomClientReaderThread implements Runnable {
  19.     private Socket socket;
  20.     private BufferedReader br ;
  21.     private PrintWriter pw;
  22.     private ClientFrame frame;
  25.     public ChatRoomClientReaderThread(Socket socket,ClientFrame frame) throws IOException {
  26.         this.socket = socket;
  27.         this.frame = frame;
  28.         br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  29.         pw = new PrintWriter(socket.getOutputStream(),true);
  30.     }
  34.     @Override
  35.     public void run() {
  36.         String str = null;
  37.         try {
  38.             while((str = br.readLine())!=null){
  39.                 Date date = new Date();
  40.                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  41.                 System.out.println("客户端接收的消息是："+str);
  42.                 Message msg = 
  43.                     (Message) JSONObject.toBean
  44.                         (JSONObject.fromObject(str), Message.class);
  45.                 switch (msg.getType()) {
  46.                 case 4: //系统登录消息。
  47.                     User userLogin = msg.getFromUser();
  48.                     if(userLogin.equals(frame.getUser())){
  49.                         frame.getArea().append("[系统消息]:您成功上线了！\r\n");
  50.                     }else{
  51.                         frame.getArea().append("[系统消息]:您的好友"+userLogin.getNickname()+"("+userLogin.getUsername()+")上线了！\r\n");
  52.                         //好友列表增加用户
  53.                         FriendsTreeFlushUtil.insert(frame, userLogin);
  54.                     }
  55.                     break;
  56.                 case 5: //系统退出消息
  57.                     User out = msg.getFromUser();
  58.                     frame.getArea().append("[系统消息]:您的好友"+out.getNickname()+"("+out.getUsername()+")下线了！\r\n");
  59.                     //在好友列表中移除退出的用户
  60.                     FriendsTreeFlushUtil.remove(frame, out);
  61.                     break;
  62.                 case 22: //客户端接收的私聊消息
  63.                     User fromUser = msg.getFromUser();
  64.                     String msgStr = msg.getMessage();
  65.                     frame.getArea().append("【私聊】"+fromUser.getNickname()
  66.                             +"("+fromUser.getUsername()+") "+sdf.format(date)+" 说:");
  67.                     frame.getArea().append(msgStr+"\r\n");
  68.                     break;
  69.                 case 23: //客户端接收的群聊消息
  70.                     User fromU = msg.getFromUser();
  71.                     String msgS = msg.getMessage();
  72.                     if(!frame.getUser().equals(fromU)){
  73.                         frame.getArea().append("【群聊】"+fromU.getNickname()
  74.                                 +"("+fromU.getUsername()+") "+sdf.format(date)+" 说:");
  75.                         frame.getArea().append(msgS+"\r\n");
  76.                     }
  77.                     break;
  78.                 }
  80.             }
  81.         } catch (IOException e) {
  82.             e.printStackTrace();
  83.         }
  84.     }
  85. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85

Message

  1. package sram.user;
  3. //用来描述发送消息的类。 1登陆（10 成功  11 不成功） 2 (服务器（20 私聊   21 群聊）客户端（  22 私聊，23群聊 )聊天 3退出  4系统登录消息  5 系统退出消息等
  4. public class Message {
  5.     private String message; //发送消息内容
  6.     private int type; //发送消息类型
  7.     private User fromUser; //来源自谁的消息
  8.     private User toUser; //发送给谁
  10.     public String getMessage() {
  11.         return message;
  12.     }
  13.     public void setMessage(String message) {
  14.         this.message = message;
  15.     }
  16.     public int getType() {
  17.         return type;
  18.     }
  19.     public void setType(int type) {
  20.         this.type = type;
  21.     }
  22.     public User getFromUser() {
  23.         return fromUser;
  24.     }
  25.     public void setFromUser(User fromUser) {
  26.         this.fromUser = fromUser;
  27.     }
  28.     public User getToUser() {
  29.         return toUser;
  30.     }
  31.     public void setToUser(User toUser) {
  32.         this.toUser = toUser;
  33.     }
  34. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34

User

  1. package sram.user;
  2. //用户实体类。登陆成功后，可以被保存在服务器端。
  3. public class User {
  4.     private String username; //用户名，唯一的标识
  5.     private String nickname;//用户自定义的网络名称
  8.     public String getUsername() {
  9.         return username;
  10.     }
  11.     public void setUsername(String username) {
  12.         this.username = username;
  13.     }
  14.     public String getNickname() {
  15.         return nickname;
  16.     }
  17.     public void setNickname(String nickname) {
  18.         this.nickname = nickname;
  19.     }
  20.     public User(String username, String nickname) {
  21.         this.username = username;
  22.         this.nickname = nickname;
  23.     }
  24.     public User() {
  25.     }
  26.     @Override
  27.     public boolean equals(Object obj) {
  28.         User user = (User)obj;
  29.         return this.username.equals(user.username);
  30.     }
  31.     @Override
  32.     public String toString() {
  33.         return nickname+"("+username+")";
  34.     }    
  35. }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35

FriendsTreeFlushUtil

  1. package sram.util;
  3. import java.util.Enumeration;
  5. import javax.swing.tree.DefaultMutableTreeNode;
  6. import javax.swing.tree.DefaultTreeModel;
  8. import sram.frame.ClientFrame;
  9. import sram.user.User;
  11. public class FriendsTreeFlushUtil {
  12.     public static void insert(ClientFrame frame,User u){
  13.         DefaultMutableTreeNode root = frame.getRoot();
  14.         DefaultTreeModel model = frame.getModel();
  15.         model.insertNodeInto(new DefaultMutableTreeNode(u), root, root.getChildCount());
  16.     }
  17.     public static void remove(ClientFrame frame,User u){
  18.         DefaultMutableTreeNode root = frame.getRoot();
  19.         DefaultTreeModel model = frame.getModel();
  20.         //获取所有的子节点
  21.         Enumeration<DefaultMutableTreeNode> children =  root.children();
  22.         while(children.hasMoreElements()){
  23.             DefaultMutableTreeNode node = children.nextElement();
  24.             User user = (User) node.getUserObject();
  25.             if(user.equals(u)){
  26.                 model.removeNodeFromParent(node);
  27.             }
  28.         }
  30.     }    
  31. }

发表评论

表情：
评论列表 （有 0 条评论，277人围观）

还没有评论，来说两句吧...

相关阅读