一、QQ 聊天项目演示

 在运运行过程出现的异常，应该是类的序列化不一致导致的

1 项目 QQ 演示

 

2 为什么选择这个项目 

只做核心部分，界面相对弱化

3 项目开发流程 

 3.1 需求分析

3.2  界面设计 

3.2.1 用户登录 

 3.2.2 拉取在线用户列表

3.2.3私聊 

 3.2.4 群聊

3.2.5 发文件 

3.2.6 文件服务器推送新闻 

二、功能实现

 1.功能实现-用户登录

 

2.功能实现-拉取在线用户列表

思路：客户端向服务器发送消息，消息类型为拉取在线用户列表，服务器识别，返回线程管理集合中的所有用户ID，并会回送给客户端，客户端接收后向用户输出

 

3 功能实现-无异常退出

4 功能实现-私聊

5.功能实现-群聊

群聊思路跟私聊差不多，就是在私聊的代码上更改，遍历服务器管理的线程集合【排除自己就欧克】 

6 功能说明-发文件

7 功能实现-服务器推送新闻

三、代码

服务端

1.【package com.hspedu.qq.service;】 

1.1【class ManageClientThreads】

package com.hspedu.qq.service;import java.util.HashMap;
import java.util.Set;/*** @author 林然* @version 1.0* 管理和客户端通讯的线程*/
public class ManageClientThreads {private static HashMap<String,ServerConnnectClientThread> hm=new HashMap<>();//添加线程对象到hm集合public static void add_(String userId,ServerConnnectClientThread serverConnnectClientThread){hm.put(userId,serverConnnectClientThread);}//获取 根据一个userid获取对应的线程public static ServerConnnectClientThread get_Thread(String userId){return hm.get(userId);}//从集合中移除某个线程对象public static void remove_Thread(String userId){hm.remove(userId);}//编写一个方法，返回在线用户列表public static String getOnlineUsers(){Set<String> keys=hm.keySet();String onlineUserList="";for (Object key:keys){onlineUserList+=key+" ";}return onlineUserList;}
}

1.2【class QQServer】

package com.hspedu.qq.service;import com.hspedu.qqcommon.*;import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ConcurrentHashMap;/*** @author 林然* @version 1.0* 这是服务器，在监听9999端口，等待客户端的连接，并保持通讯*/
public class QQServer {private ServerSocket serverSocket =null;//创建一个集合，存放多个用户，如果是这些用户登录就认为是合法的//这里我们也可以使用concurrentHashMap,可以处理并发的集合，// HashMap没有线程安全,因此在多线程情况下不安全private static ConcurrentHashMap<String,User> vaildUsers =new ConcurrentHashMap<>();static {//在静态代码块初始化vaildUsersvaildUsers.put("100",new User("100","123456"));vaildUsers.put("200",new User("200","123456"));vaildUsers.put("300",new User("300","123456"));vaildUsers.put("至尊宝",new User("至尊宝","123456"));vaildUsers.put("紫霞仙子",new User("紫霞仙子","123456"));vaildUsers.put("菩提老祖",new User("菩提老祖","123456"));}//验证用户是否有效的方法private boolean checkUser(String userId,String passwd){User user = vaildUsers.get(userId);if(user==null){//说明userId没有存在return false;}if(!(user.getPassword().equals(passwd))){return false;}return true;}public QQServer(){System.out.println("服务器在9999端口监听。。。。。");try {sendNewsToall sendNewsToall = new sendNewsToall();new Thread(sendNewsToall).start();serverSocket=new ServerSocket(9999);while (true){//当和某个客户端会继续监听，因此使用while循环Socket socket= serverSocket.accept();//如果没有客户端连接，就会阻塞//得到socket关联的对象输入流ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());User user=(User)objectInputStream.readObject();//读取相关的对象输入流//得到socket对象关联的输出流ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());//创建一个message对象。准备回复客户端Message message =new Message();//验证if(checkUser(user.getUserid(),user.getPassword())){//登录成功message.setMessageType(MessageType.MESSAGE_LOGIN_SUCCEED);//将message对象回复客户端objectOutputStream.writeObject(message);//创建一个线程和客户端保持通讯，该线程需要持有socket对象ServerConnnectClientThread serverConnnectClientThread = new ServerConnnectClientThread(socket, user.getUserid());serverConnnectClientThread.start();//将线程对象加入到集合中进行管理ManageClientThreads.add_(user.getUserid(),serverConnnectClientThread);}else {//登录失败System.out.println("用户 id="+user.getUserid()+"  pw="+user.getPassword()+"验证失败");message.setMessageType(MessageType.MESSAGE_LOGIN_FAIL);//将message对象回复客户端objectOutputStream.writeObject(message);//关闭socketsocket.close();}}} catch (IOException | ClassNotFoundException e) {e.printStackTrace();}finally {try {//如果服务端退出while，那么说明服务端不在监听，因此关闭serverSocketserverSocket.close();} catch (IOException e) {e.printStackTrace();}}}
}

1.3【class sendNewsToall】

package com.hspedu.qq.service;import com.hspedu.qqcommon.*;import com.hspedu.utils.Utility;import java.io.IOException;
import java.io.ObjectOutputStream;
import java.util.Date;
import java.util.Scanner;/*** @author 林然* @version 1.0*/
public class sendNewsToall implements Runnable {private Scanner scanner =new Scanner(System.in);@Overridepublic void run() {while (true){System.out.println("请输入服务器要发送的新闻/消息【输入exit】表示退出推送服务");String news = Utility.readString(1000);//构建一个消息，群发消息if(news.equals("exit")){System.out.println("推送服务已关闭");break;}Message message =new Message();message.setSender("服务器");message.setContent(news);message.setSendTime(new Date().toString());message.setMessageType(MessageType.MESSAGE_ALL_MES);System.out.println("服务器推送消息："+news);//遍历String [] userList =ManageClientThreads.getOnlineUsers().split(" ");for(int i=0;i<userList.length;i++){try {ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientThreads.get_Thread(userList[i]).getSocket().getOutputStream());objectOutputStream.writeObject(message);} catch (IOException e) {e.printStackTrace();}}}}
}

1.4【class ServerConnnectClientThread】

package com.hspedu.qq.service;import com.hspedu.qqcommon.*;
import com.hspedu.qqcommon.MessageType;import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;/*** @author 林然* @version 1.0* 该类对应的对象和某个客户端保持通讯*/
public class ServerConnnectClientThread extends Thread{private Socket socket;private String useId;//连接到服务端的用户idpublic ServerConnnectClientThread(Socket socket, String useId) {this.socket = socket;this.useId = useId;}public Socket getSocket() {return socket;}@Overridepublic void run() {//线程处于run的状态，可以发送/接收消息while (true){System.out.println("服务端和客户端"+useId+"保持通讯，读取数据.....");try {ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());Message message=(Message) objectInputStream.readObject();if(message.getMessageType().equals(MessageType.MESSAGE_GET_ONLINE_FRIEND)){//客户端需要在线用户列表System.out.println(message.getSender()+"需要在线用户列表");String onlineFriendList =ManageClientThreads.getOnlineUsers();Message rs =new Message();rs.setContent(onlineFriendList);rs.setMessageType(MessageType.MESSAGE_RETURN_ONLINE_FRIEND);rs.setGetter("服务端");//写入到数据通道返回给客户端ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());objectOutputStream.writeObject(rs);}else if(message.getMessageType().equals(MessageType.MESSAGE_CLIENT_EXIT)){System.out.println(message.getSender()+"退出系统");//将客户端对应的线程，从集合删除ManageClientThreads.remove_Thread(useId);socket.close();//退出线程break;}else if(message.getMessageType().equals(MessageType.MESSAGE_COMM_MES)){//发送消息类ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientThreads.get_Thread(message.getGetter()).getSocket().getOutputStream());objectOutputStream.writeObject(message);//转发，如果客户不在线可以保存到数据库，这样就可以实现离线留言}else if(message.getMessageType().equals(MessageType.MESSAGE_ALL_MES)){String [] userLine =ManageClientThreads.getOnlineUsers().split(" ");for(int i=0;i<userLine.length;i++){if(!userLine[i].equals(message.getSender())){ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientThreads.get_Thread(userLine[i]).getSocket().getOutputStream());objectOutputStream.writeObject(message);}}}else if(message.getMessageType().equals(MessageType.MESSAGE_FILE_MES)){//根据getId获取对应的线程ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientThreads.get_Thread(message.getGetter()).getSocket().getOutputStream());objectOutputStream.writeObject(message);}else {System.out.println("如果是其他类型的message,暂时不处理");}} catch (IOException | ClassNotFoundException e) {e.printStackTrace();}}}
}

2【package com.hspedu.qqcommon;】

2.1【class Message】

package com.hspedu.qqcommon;import java.io.Serializable;/*** @author 林然* @version 1.0*/
public class Message implements Serializable {//序列化后为了增强兼容性private static final long serialVersionID=1L;private String sender;//表示发送者private String getter;//表示接收者private String content;//表示发送内容private String sendTime;//表示发送时间private String messageType;//表示消息类型【可以在接口中定义消息类型】//消息类进行扩展和文件相关的字段和成员private byte [] fileBytes ;private int fileLength =0;private String dest;//将文件传输到哪里private String src;//源文件路径public byte[] getFileBytes() {return fileBytes;}public void setFileBytes(byte[] fileBytes) {this.fileBytes = fileBytes;}public int getFileLength() {return fileLength;}public void setFileLength(int fileLength) {this.fileLength = fileLength;}public String getDest() {return dest;}public void setDest(String dest) {this.dest = dest;}public String getSrc() {return src;}public void setSrc(String src) {this.src = src;}public String getSender() {return sender;}public void setSender(String sender) {this.sender = sender;}public String getGetter() {return getter;}public void setGetter(String getter) {this.getter = getter;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}public String getSendTime() {return sendTime;}public void setSendTime(String sendTime) {this.sendTime = sendTime;}public String getMessageType() {return messageType;}public void setMessageType(String messageType) {this.messageType = messageType;}
}

 2.2【interface MessageType】

package com.hspedu.qqcommon;/*** @author 林然* @version 1.0* 表示消息类型*/
public interface MessageType {//在接口中定义了一些常量，不同常量的值，表示不同的消息类型String MESSAGE_LOGIN_SUCCEED ="1";//表示登录成功String MESSAGE_LOGIN_FAIL ="2";//表示登录失败String MESSAGE_COMM_MES ="3";//普通信息对象String MESSAGE_GET_ONLINE_FRIEND="4";//要求返回在线用户列表String MESSAGE_RETURN_ONLINE_FRIEND="5";//要求返回在线用户列表String MESSAGE_CLIENT_EXIT="6";//客户端请求退出String MESSAGE_ALL_MES ="7";//群发信息对象String MESSAGE_FILE_MES ="8";//发送文件}

 2.3【class User】

package com.hspedu.qqcommon;import java.io.Serializable;/*** @author 林然* @version 1.0* 表示一个用户/客户信息*/
public class User implements Serializable {//序列化后为了增强兼容性private static final long serialVersionID=2L;private String userid;//用户idprivate String password ;//用户密码public User() {}public User(String userid, String password) {this.userid = userid;this.password = password;}public String getUserid() {return userid;}public void setUserid(String userid) {this.userid = userid;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}
}

 3【com.hspedu.qqframe;】

package com.hspedu.qqframe;import com.hspedu.qq.service.QQServer;/*** @author 林然* @version 1.0* 该类创建一个QQServer对象*/
public class QQFrame {public static void main(String[] args) {new QQServer();}
}

 4【com.hspedu.utils】

package com.hspedu.utils;/**工具类的作用:处理各种情况的用户输入，并且能够按照程序员的需求，得到用户的控制台输入。
*/import java.util.Scanner;/***/
public class Utility {//静态属性。。。private static Scanner scanner = new Scanner(System.in);/*** 功能：读取键盘输入的一个菜单选项，值：1——5的范围* @return 1——5*/public static char readMenuSelection() {char c;for (; ; ) {String str = readKeyBoard(1, false);//包含一个字符的字符串c = str.charAt(0);//将字符串转换成字符char类型if (c != '1' && c != '2' && c != '3' && c != '4' && c != '5') {System.out.print("选择错误，请重新输入：");} else break;}return c;}/*** 功能：读取键盘输入的一个字符* @return 一个字符*/public static char readChar() {String str = readKeyBoard(1, false);//就是一个字符return str.charAt(0);}/*** 功能：读取键盘输入的一个字符，如果直接按回车，则返回指定的默认值；否则返回输入的那个字符* @param defaultValue 指定的默认值* @return 默认值或输入的字符*/public static char readChar(char defaultValue) {String str = readKeyBoard(1, true);//要么是空字符串，要么是一个字符return (str.length() == 0) ? defaultValue : str.charAt(0);}/*** 功能：读取键盘输入的整型，长度小于2位* @return 整数*/public static int readInt() {int n;for (; ; ) {String str = readKeyBoard(2, false);//一个整数，长度<=2位try {n = Integer.parseInt(str);//将字符串转换成整数break;} catch (NumberFormatException e) {System.out.print("数字输入错误，请重新输入：");}}return n;}/*** 功能：读取键盘输入的 整数或默认值，如果直接回车，则返回默认值，否则返回输入的整数* @param defaultValue 指定的默认值* @return 整数或默认值*/public static int readInt(int defaultValue) {int n;for (; ; ) {String str = readKeyBoard(10, true);if (str.equals("")) {return defaultValue;}//异常处理...try {n = Integer.parseInt(str);break;} catch (NumberFormatException e) {System.out.print("数字输入错误，请重新输入：");}}return n;}/*** 功能：读取键盘输入的指定长度的字符串* @param limit 限制的长度* @return 指定长度的字符串*/public static String readString(int limit) {return readKeyBoard(limit, false);}/*** 功能：读取键盘输入的指定长度的字符串或默认值，如果直接回车，返回默认值，否则返回字符串* @param limit 限制的长度* @param defaultValue 指定的默认值* @return 指定长度的字符串*/public static String readString(int limit, String defaultValue) {String str = readKeyBoard(limit, true);return str.equals("")? defaultValue : str;}/*** 功能：读取键盘输入的确认选项，Y或N* 将小的功能，封装到一个方法中.* @return Y或N*/public static char readConfirmSelection() {System.out.println("请输入你的选择(Y/N)");char c;for (; ; ) {//无限循环//在这里，将接受到字符，转成了大写字母//y => Y n=>NString str = readKeyBoard(1, false).toUpperCase();c = str.charAt(0);if (c == 'Y' || c == 'N') {break;} else {System.out.print("选择错误，请重新输入：");}}return c;}/*** 功能： 读取一个字符串* @param limit 读取的长度* @param blankReturn 如果为true ,表示 可以读空字符串。 * 					  如果为false表示 不能读空字符串。* 			*	如果输入为空，或者输入大于limit的长度，就会提示重新输入。* @return*/private static String readKeyBoard(int limit, boolean blankReturn) {//定义了字符串String line = "";//scanner.hasNextLine() 判断有没有下一行while (scanner.hasNextLine()) {line = scanner.nextLine();//读取这一行//如果line.length=0, 即用户没有输入任何内容，直接回车if (line.length() == 0) {if (blankReturn) return line;//如果blankReturn=true,可以返回空串else continue; //如果blankReturn=false,不接受空串，必须输入内容}//如果用户输入的内容大于了 limit，就提示重写输入  //如果用户如的内容 >0 <= limit ,我就接受if (line.length() < 1 || line.length() > limit) {System.out.print("输入长度（不能大于" + limit + "）错误，请重新输入：");continue;}break;}return line;}
}

客户端

1.【package com.hspedu.qqclient.service】 

1.1【class ClientConnectServerThread】 

package com.hspedu.qqclient.service;import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;import java.io.*;
import java.net.Socket;/*** @author 林然* @version 1.0*/
public class ClientConnectServerThread extends Thread {//该线程需要持有Socketprivate Socket socket;//构造器可以接受一个socket对象public ClientConnectServerThread(Socket socket){this.socket=socket;}@Overridepublic void run() {//因为Thread需要在后台和服务器通讯，因此我们做成一个while循环while (true){System.out.println("客户端线程，等待读取从服务器端发送的消息");try {ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());//如果服务器没有信息发送，会一直阻塞在这里Message ms=(Message)objectInputStream.readObject();//在这里判断message类型，然后做相应的处理//如果是服务端的拉去好友在线列表if(ms.getMessageType().equals(MessageType.MESSAGE_RETURN_ONLINE_FRIEND)){//取出在线列表信息，并显示//规定String [] online_users=ms.getContent().split(" ");System.out.println("==========在线用户列表如下");for (int i = 0; i < online_users.length; i++) {System.out.println("用户："+online_users[i]);}}else if(ms.getMessageType().equals(MessageType.MESSAGE_COMM_MES)){//显示即可System.out.println(ms.getSendTime());System.out.println("\n"+ms.getSender()+" 对你说："+ms.getContent());}else if(ms.getMessageType().equals(MessageType.MESSAGE_ALL_MES)){System.out.println(ms.getSendTime());System.out.println("\n"+ms.getSender()+" 对大家说："+ms.getContent());}else if(ms.getMessageType().equals(MessageType.MESSAGE_FILE_MES)){//提示信息System.out.println("\n"+ms.getSender()+" 发送文件 "+ms.getSrc()+" 到 "+" 电脑目录 "+ms.getDest());File file =new File(ms.getDest());FileOutputStream fileOutputStream =new FileOutputStream(file);fileOutputStream.write(ms.getFileBytes());fileOutputStream.close();System.out.println("\n保存文件成功");}else {System.out.println("如果是其他类型的message,暂时不处理");}} catch (IOException | ClassNotFoundException e) {e.printStackTrace();}}}//为了更方便得到socketpublic Socket getSocket() {return socket;}public void setSocket(Socket socket) {this.socket = socket;}
}

 1.2【class FileClientService 】

package com.hspedu.qqclient.service;import com.hspedu.qqclient.utils.Utility;
import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;import java.io.*;/*** @author 林然* @version 1.0* 该类完成文件传输*/
public class FileClientService {public void sendFileOne(String sendId){System.out.println(" 请输入想要发送文件的用户名（在线）：");String getterId= Utility.readString(50);System.out.println(" 请输入传输的本地文件路径(形式d:\\xx.jpg)：");String src=Utility.readString(100);System.out.println(" 请输入对方文件存储的本地文件路径(形式d:\\xx.jpg)：");String dest=Utility.readString(100);Message message =new Message();message.setSender(sendId);message.setMessageType(MessageType.MESSAGE_FILE_MES);message.setGetter(getterId);message.setDest(dest);message.setSrc(src);//需要将文件进行读取File file =new File(src);byte [] filebytes =new byte[(int)(file.length())];try {FileInputStream fileInputStream =new FileInputStream(file);fileInputStream.read(filebytes);//将src文件读取到程序的字节数组//将文件字节数组设置到message对象中message.setFileBytes(filebytes);if(fileInputStream!=null){fileInputStream.close();}} catch (IOException e) {e.printStackTrace();}finally {}//提示信息System.out.println("\n"+" 发送文件 "+src+" 到 "+getterId+" 的电脑目录 "+dest);//发送时。获取对象输出流try {ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());objectOutputStream.writeObject(message);} catch (IOException e) {e.printStackTrace();}}}

1.3【class ManageClientConnectSerVerThread】 

package com.hspedu.qqclient.service;import java.util.HashMap;/*** @author 林然* @version 1.0* 该类管理客户端连接到服务端的线程的类*/
public class ManageClientConnectSerVerThread {//我们把多个线程，放入到hashmap集合，key就是用户id，val就是线程private static HashMap<String,ClientConnectServerThread> hm=new HashMap<>();//将某个线程加入集合public static  void add_Thread(String userId,ClientConnectServerThread clientConnectServerThread){hm.put(userId,clientConnectServerThread);}//通过一个userId可以得到对应的线程public static ClientConnectServerThread get_Thread(String userId){return hm.get(userId);}//从集合中移除某个线程对象public static void remove_Thread(String userId){hm.remove(userId);}}

1.4【class MessageClientSrevice】

package com.hspedu.qqclient.service;import com.hspedu.qqclient.utils.Utility;
import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;import java.io.IOException;
import java.io.ObjectOutputStream;/*** @author 林然* @version 1.0* 该类提供和消息相关的服务方法*/
public class MessageClientSrevice {public void sendMessageToAll(String sendId){System.out.print(" 请输入想要说的话：");String content=Utility.readString(100);Message message =new Message();message.setMessageType(MessageType.MESSAGE_ALL_MES);message.setSender(sendId);message.setContent(content);message.setSendTime(new java.util.Date().toString());//发送时间try {ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());objectOutputStream.writeObject(message);} catch (IOException e) {e.printStackTrace();}}public  void sendMessageToOne(String sendId){System.out.print(" 请输入想要聊天的用户名（在线）：");String getterId= Utility.readString(50);System.out.print(" 请输入想要说的话：");String content=Utility.readString(100);//构建messageMessage message=new Message();message.setSender(sendId);message.setGetter(getterId);message.setContent(content);message.setSendTime(new java.util.Date().toString());//发送时间message.setMessageType(MessageType.MESSAGE_COMM_MES);System.out.println(sendId+"对"+getterId+"说了一句话");//发送给服务端try {ObjectOutputStream objectOutputStream = new ObjectOutputStream(ManageClientConnectSerVerThread.get_Thread(sendId).getSocket().getOutputStream());objectOutputStream.writeObject(message);} catch (IOException e) {e.printStackTrace();}}
}

 1.5【class UserClientService】

package com.hspedu.qqclient.service;import com.hspedu.qqcommon.Message;
import com.hspedu.qqcommon.MessageType;
import com.hspedu.qqcommon.User;import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;/*** @author 林然* @version 1.0* 该类完成用户登录验证注册等功能*/
public class UserClientService {//根据Userid和pwd验证该用户是否合法//因为我们可能在其他地方要使用user信息，所以做成属性private User u =new User();//因为Socket在其他地方也可能要使用，所以我们也做成属性private Socket socket;public boolean checkUser(String userId,String pwd) throws IOException, ClassNotFoundException {boolean b=false;u.setPassword(pwd);u.setUserid(userId);//连接服务端，发送user对象Socket socket = new Socket(InetAddress.getLocalHost(), 9999);//得到ObjectOutput对象ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());//发送user对象objectOutputStream.writeObject(u);//读取从服务端回复的message对象ObjectInputStream objectInputStream =new ObjectInputStream(socket.getInputStream());Message ms=(Message) objectInputStream.readObject();if(ms.getMessageType().equals(MessageType.MESSAGE_LOGIN_SUCCEED)){//登录ok//创建一个和服务器端保持通讯的线程->创建一个类 ClientConnectServerThread//等待....ClientConnectServerThread clientConnectServerThread=new ClientConnectServerThread(socket);//启动客户端的线程clientConnectServerThread.start();//这里为了后面客户端的扩展，我们将线程放入到集合中进行管理ManageClientConnectSerVerThread.add_Thread(userId,clientConnectServerThread);b=true;}else {//登录失败socket.close();}return b;}//向服务端请求在线用户列表public void onlineFriendList(){Message message =new Message();message.setMessageType(MessageType.MESSAGE_GET_ONLINE_FRIEND);message.setSender(u.getUserid());//发送给服务器，应该得到当前线程对象的socket对应的objectOutputstreamtry {ObjectOutputStream objectOutputStream =new ObjectOutputStream(ManageClientConnectSerVerThread.get_Thread(u.getUserid()).getSocket().getOutputStream());objectOutputStream.writeObject(message);} catch (IOException e) {e.printStackTrace();}}//编写方法。退出2客户端，并给服务端发送一个退出系统的message对象public void Logout(){Message message =new Message();message.setMessageType(MessageType.MESSAGE_CLIENT_EXIT);message.setSender(u.getUserid());//发送messagetry {ObjectOutputStream objectOutputStream = new ObjectOutputStream(ManageClientConnectSerVerThread.get_Thread(u.getUserid()).getSocket().getOutputStream());objectOutputStream.writeObject(message);System.out.println(u.getUserid()+"退出系统");System.exit(0);//结束} catch (IOException e) {e.printStackTrace();}}}

 2【package com.hspedu.qqclient.utils;】

package com.hspedu.qqclient.utils;/**工具类的作用:处理各种情况的用户输入，并且能够按照程序员的需求，得到用户的控制台输入。
*/import java.util.Scanner;/***/
public class Utility {//静态属性。。。private static Scanner scanner = new Scanner(System.in);/*** 功能：读取键盘输入的一个菜单选项，值：1——5的范围* @return 1——5*/public static char readMenuSelection() {char c;for (; ; ) {String str = readKeyBoard(1, false);//包含一个字符的字符串c = str.charAt(0);//将字符串转换成字符char类型if (c != '1' && c != '2' && c != '3' && c != '4' && c != '5') {System.out.print("选择错误，请重新输入：");} else break;}return c;}/*** 功能：读取键盘输入的一个字符* @return 一个字符*/public static char readChar() {String str = readKeyBoard(1, false);//就是一个字符return str.charAt(0);}/*** 功能：读取键盘输入的一个字符，如果直接按回车，则返回指定的默认值；否则返回输入的那个字符* @param defaultValue 指定的默认值* @return 默认值或输入的字符*/public static char readChar(char defaultValue) {String str = readKeyBoard(1, true);//要么是空字符串，要么是一个字符return (str.length() == 0) ? defaultValue : str.charAt(0);}/*** 功能：读取键盘输入的整型，长度小于2位* @return 整数*/public static int readInt() {int n;for (; ; ) {String str = readKeyBoard(2, false);//一个整数，长度<=2位try {n = Integer.parseInt(str);//将字符串转换成整数break;} catch (NumberFormatException e) {System.out.print("数字输入错误，请重新输入：");}}return n;}/*** 功能：读取键盘输入的 整数或默认值，如果直接回车，则返回默认值，否则返回输入的整数* @param defaultValue 指定的默认值* @return 整数或默认值*/public static int readInt(int defaultValue) {int n;for (; ; ) {String str = readKeyBoard(10, true);if (str.equals("")) {return defaultValue;}//异常处理...try {n = Integer.parseInt(str);break;} catch (NumberFormatException e) {System.out.print("数字输入错误，请重新输入：");}}return n;}/*** 功能：读取键盘输入的指定长度的字符串* @param limit 限制的长度* @return 指定长度的字符串*/public static String readString(int limit) {return readKeyBoard(limit, false);}/*** 功能：读取键盘输入的指定长度的字符串或默认值，如果直接回车，返回默认值，否则返回字符串* @param limit 限制的长度* @param defaultValue 指定的默认值* @return 指定长度的字符串*/public static String readString(int limit, String defaultValue) {String str = readKeyBoard(limit, true);return str.equals("")? defaultValue : str;}/*** 功能：读取键盘输入的确认选项，Y或N* 将小的功能，封装到一个方法中.* @return Y或N*/public static char readConfirmSelection() {System.out.println("请输入你的选择(Y/N)");char c;for (; ; ) {//无限循环//在这里，将接受到字符，转成了大写字母//y => Y n=>NString str = readKeyBoard(1, false).toUpperCase();c = str.charAt(0);if (c == 'Y' || c == 'N') {break;} else {System.out.print("选择错误，请重新输入：");}}return c;}/*** 功能： 读取一个字符串* @param limit 读取的长度* @param blankReturn 如果为true ,表示 可以读空字符串。 * 					  如果为false表示 不能读空字符串。* 			*	如果输入为空，或者输入大于limit的长度，就会提示重新输入。* @return*/private static String readKeyBoard(int limit, boolean blankReturn) {//定义了字符串String line = "";//scanner.hasNextLine() 判断有没有下一行while (scanner.hasNextLine()) {line = scanner.nextLine();//读取这一行//如果line.length=0, 即用户没有输入任何内容，直接回车if (line.length() == 0) {if (blankReturn) return line;//如果blankReturn=true,可以返回空串else continue; //如果blankReturn=false,不接受空串，必须输入内容}//如果用户输入的内容大于了 limit，就提示重写输入  //如果用户如的内容 >0 <= limit ,我就接受if (line.length() < 1 || line.length() > limit) {System.out.print("输入长度（不能大于" + limit + "）错误，请重新输入：");continue;}break;}return line;}
}

 3【package com.hspedu.qqclient.view;】

package com.hspedu.qqclient.view;import com.hspedu.qqclient.service.FileClientService;
import com.hspedu.qqclient.service.MessageClientSrevice;
import com.hspedu.qqclient.service.UserClientService;
import com.hspedu.qqclient.utils.Utility;import java.io.IOException;/*** @author 林然* @version 1.0* 客户端菜单界面*/
public class QQView {private boolean loop = true;//控制是否显示菜单private String key = "";//接受用户输入private UserClientService userClientService=new UserClientService();//用于登录注册服务private MessageClientSrevice messageClientSrevice =new MessageClientSrevice();//消息服务private FileClientService fileClientService =new FileClientService();//传输文件服务public static void main(String[] args) throws IOException, ClassNotFoundException {new QQView().mainMenu();System.out.println("客户端退出系统");}//显示主菜单private void mainMenu() throws IOException, ClassNotFoundException {while (loop) {System.out.println("===========================欢迎登录网络通信系统===================================");System.out.println("\t\t 1 登录系统");System.out.println("\t\t 9 退出系统");System.out.println("请输入你的选择");key = Utility.readString(1);//根据用户不同的输入来处理不同的逻辑switch (key){case "1":System.out.println("请输入用户号：");String userId = Utility.readString(50);System.out.println("请输入密码：");String pwd = Utility.readString(50);//这里就比较麻烦了，需要到服务端去验证用户是否合法//这里有很多代码，我们需要编写一个类UserClientService【用户登录等if(userClientService.checkUser(userId,pwd)){//还没有写完，先把整个逻辑打通System.out.println("===========================欢迎(用户"+userId+")登录成功===================================");//进入二级菜单while (loop){System.out.println("\n=====================网络通信系统二级菜单（用户"+userId+"===================");System.out.println("\t\t 1 显示在线用户列表");System.out.println("\t\t 2 群发消息");System.out.println("\t\t 3 私聊消息");System.out.println("\t\t 4 发送文件");System.out.println("\t\t 9 退出系统");System.out.println("请输入你的选择");key = Utility.readString(1);switch (key){case "1"://System.out.println(" 1 显示在线用户列表");//这里准备写一个方法来获取在线用户列表userClientService.onlineFriendList();break;case "2"://System.out.println(" 2 群发消息");messageClientSrevice.sendMessageToAll(userId);break;case "3":messageClientSrevice.sendMessageToOne(userId);//调用一个方法break;case "4"://System.out.println(" 4 发送文件");fileClientService.sendFileOne(userId);break;case "9"://调用一个方法给服务器发送一个退出系统的message//System.out.println(" 9 退出系统");userClientService.Logout();loop=false;break;}}}else {System.out.println(" 登录失败");}break;case "9":loop=false;userClientService.Logout();break;}}}
}

 4【package com.hspedu.qqcommon;】

4.1【class Message】

package com.hspedu.qqcommon;import java.io.Serializable;/*** @author 林然* @version 1.0* 表示客户端和服务器端通讯的消息*/
public class Message implements Serializable {//序列化后为了增强兼容性private static final long serialVersionID=1L;private String sender;//表示发送者private String getter;//表示接收者private String content;//表示发送内容private String sendTime;//表示发送时间private String messageType;//表示消息类型【可以在接口中定义消息类型】//消息类进行扩展和文件相关的字段和成员private byte [] fileBytes ;private int fileLength =0;private String dest;//将文件传输到哪里private String src;//源文件路径public byte[] getFileBytes() {return fileBytes;}public void setFileBytes(byte[] fileBytes) {this.fileBytes = fileBytes;}public int getFileLength() {return fileLength;}public void setFileLength(int fileLength) {this.fileLength = fileLength;}public String getDest() {return dest;}public void setDest(String dest) {this.dest = dest;}public String getSrc() {return src;}public void setSrc(String src) {this.src = src;}public String getSender() {return sender;}public void setSender(String sender) {this.sender = sender;}public String getGetter() {return getter;}public void setGetter(String getter) {this.getter = getter;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}public String getSendTime() {return sendTime;}public void setSendTime(String sendTime) {this.sendTime = sendTime;}public String getMessageType() {return messageType;}public void setMessageType(String messageType) {this.messageType = messageType;}
}

4.2 【interface MessageType】

package com.hspedu.qqcommon;/*** @author 林然* @version 1.0* 表示消息类型*/
public interface MessageType {//在接口中定义了一些常量，不同常量的值，表示不同的消息类型String MESSAGE_LOGIN_SUCCEED ="1";//表示登录成功String MESSAGE_LOGIN_FAIL ="2";//表示登录失败String MESSAGE_COMM_MES ="3";//普通信息对象String MESSAGE_GET_ONLINE_FRIEND="4";//要求返回在线用户列表String MESSAGE_RETURN_ONLINE_FRIEND="5";//要求返回在线用户列表String MESSAGE_CLIENT_EXIT="6";//客户端请求退出String MESSAGE_ALL_MES ="7";//群发信息对象String MESSAGE_FILE_MES ="8";//发送文件
}

 4.3【class User】

package com.hspedu.qqcommon;import java.io.Serializable;/*** @author 林然* @version 1.0* 表示一个用户/客户信息*/
public class User implements Serializable {//序列化后为了增强兼容性private static final long serialVersionID=2L;private String userid;//用户idprivate String password ;//用户密码public User() {}public User(String userid, String password) {this.userid = userid;this.password = password;}public String getUserid() {return userid;}public void setUserid(String userid) {this.userid = userid;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}
}