day05-离线留言和离线文件
多用户即时通讯系统05
4.编码实现04（拓展）
拓展功能：
- 实现离线留言，如果某个用户不在线 ，当登陆后，可以接收离线的消息
- 实现离线发文件，如果某个功能没有在线，当登录后，可以接收离线的文件
4.8功能实现-离线留言&离线文件
4.8.1思路分析
在服务端中使用ConcurrentHashMap集合来存放离线message（后期可以连数据库）
ConcurrentHashMap存放形式为：
key = getterid [接收者id]
value = ArrayList<Message> [message对象]
- 当有客户发送消息或者文件
- 如果接收者不在线就把message对象存放到服务端的db中(ConcurrentHashMap)
- 当身为接收者的用户登录后，就到服务端的db中查找，如果有getterid = userid，就取出ArrayList的一个或者多个Message对象，发送给接收者，然后在该db中删除对应的数据
4.8.2功能实现
只需要修改服务端
1.修改QQServer类
- 在该类中创建一个ConcurrentHashMap集合 offlineMessage，用来存放用户发送的离线消息或者文件
/*
同样创建一个集合，存放多个用户发送的离线消息或者文件
使用 ConcurrentHashMap，可以处理并发的集合，没有线程安全问题
存放的形式为
key = getter id [接收者id]
value = ArrayList<Message> 在一个ArrayList集合中可以存放多条 message对象，实现多条留言或者文件
*/
static ConcurrentHashMap<String, ArrayList<Message>> offlineMessage = new ConcurrentHashMap<>();
- 在该类中新增一个方法，用来判断当用户登录时，是否需要发送离线留言给该用户
/**
* @param getterId 接收离线数据的用户userId
* @param socket 用户对应的通信socket
* 写一个方法，当有用户登录成功时，获取该用户id名，
* 在离线集合中搜索该id，如果有，就返回给该用户，然后删除该离线留言或者文件
*/
public void isOfflineMessage(String getterId,Socket socket){
//搜索 map 集合中是否有该用户的id
if (offlineMessage.containsKey(getterId)) {
//如果有，就说明该用户有离线留言或数据要接收
//在map中获取该 message数据集合arrayList
ArrayList<Message> arrayListMessage = offlineMessage.get(getterId);
//遍历arrayList集合将一个或者多个message数据发送给该用户
for (Message message:arrayListMessage) {
try {
//获得输出对象
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(message);//发送数据
} catch (IOException e) {
e.printStackTrace();
}
}
offlineMessage.remove(getterId);//遍历完则在数据库中删除该数据集合
}
}
- QQServer构造方法中的while循环中，在用户验证通过的if分支语句 的最后面调用isOfflineMessage方法
//调用方法，查看是否有离线数据
isOfflineMessage(u.getUserId(), socket);
2.修改ServerConnectClientThread类
- 在该类中新增方法processOfData()，用来判断接收用户是否在线，发送的数据应该怎样处理的问题
public void processOfData(Message message) throws IOException {
//业务三or五：客户请求给某个用户发送-->普通的聊天消息or文件
//当用户给某用户发送 message时，如果接收用户不在线（即通过getterId找不到该用户的通讯线程）
if (ManageClientThreads.getServerConnectClientThread(message.getGetter()) == null) {
//就将离线 message放入这个用户对应的arraylist集合中，再把该arrayList集合放到 map中
/*
* 这里有个缺陷，因为map的key值不允许重复（重复的话，value会覆盖为最新值），
* 所以当有多个用户分别给某一个用户进行留言，该接收用户只能接收到最近一个人的离线留言
* 为了解决这个问题，这里每次添加留言之前 都会将该接收用户的所有留言复制一份，再在 最后添加新的留言
* 然后把所有的留言再放回 map集合中，这样效果等于追加新留言
*/
// 先判断map中该接收用户的userId是否存在
// 如果有，就说明已经有人给该用户留言了，就获取map集合对应 getter id的arraylist留言表
// 然后在该用户的留言表中"追加"留言即可
if (offlineMessage.containsKey(message.getGetter())) {//如果接收用户的留言表已经存在
//获取 接收留言的用户的 留言集合
ArrayList<Message> arrayListMessage = offlineMessage.get(message.getGetter());
//在该集合中追加新的留言
arrayListMessage.add(message);//增加新的留言
//留言表再覆盖进去，这样相当于在留言表中追加留言
offlineMessage.put(message.getGetter(), arrayListMessage);
} else {//如果接收用户的留言表不存在
//如果map集合中没有接收用户的id，说明还没人给这个用户留言，要先创建一个留言表arrayListMessage
ArrayList<Message> arrayListMessage = new ArrayList<>();
//把信息添加到新创建的留言表中
arrayListMessage.add(message);
//将新留言表添加到 map集合中
offlineMessage.put(message.getGetter(), arrayListMessage);
}
} else {//接收用户在线，就直接发送数据
//根据接收的message对象的getter id 获取到对应的线程，将message对象进行转发
//先拿到线程
ServerConnectClientThread serverConnectClientThread =
ManageClientThreads.getServerConnectClientThread(message.getGetter());
//获取socket,将socket输出流转为对象流
ObjectOutputStream oos =
new ObjectOutputStream(serverConnectClientThread.getSocket().getOutputStream());
//转发
oos.writeObject(message);
}
}
- 分别修改业务三和业务五的else if分支，因为已经在方法processOfData中封装了业务，所以这里只需要调用该方法即可
业务三分支：
//业务三：客户请求和某用户私聊
//调用方法，判断用户是否在线，在线就直接发送，不在线就将message对象先存在集合中
processOfData(message);
业务五分支：
//业务五：客户请求给某用户发送文件
//调用方法，判断用户是否在线，在线就直接发送，不在线就将message对象先存在集合中
processOfData(message);
3.运行测试
1.运行服务端
2.运行客户端–用户100 分别给用户200 和用户300 发送多条离线留言
2.1用户100 登录：
2.2用户100 给用户200 发送两条离线留言：
2.3用户100 给用户300 发送两条离线留言：
3.分别登录 用户200和用户300 ，两个用户都接收到了用户100 的留言：
4.服务端监听情况：
5.多个用户对一个用户进行留言测试：
用户200不在线时，用户100和300分别给200发送了多条留言：
功能实现完毕
