?思路:1、在服務端創建一個ConcurrentHashMap線程安全的集合用來存儲離線用戶的消息和文件，為了實現每個用戶可以保存多條離線消息，我們在鍵值對value中采用ArrayList來保存多條message消息。

//存放離線留言/文件的集合private static ConcurrentHashMap<String, ArrayList<Message>> offLineDb = new ConcurrentHashMap<>();

2、?創建ArrayList集合，每個集合對應一個用戶，有多少用戶就創建多少個集合

public class ManageClientThreads {//創建存儲不在線用戶文件/消息內容的ArrayList<Message> 集合private static ArrayList<Message> arrayList1 = new ArrayList<>();private static ArrayList<Message> arrayList2 = new ArrayList<>();private static ArrayList<Message> arrayList3 = new ArrayList<>();private static ArrayList<Message> arrayList4 = new ArrayList<>();private static ArrayList<Message> arrayList5 = new ArrayList<>();private static ArrayList<Message> arrayList6 = new ArrayList<>(); }

3、 編寫一個添加內容的方法,實現把用戶對應的message數據存儲到ConcurrentHashMap集合中

//添加方法public static void addClientOffLineDb(String userid,Message message){if (userid.equals("100")) {//如果檢測到是100的用戶的信息就存在arrayList1中arrayList1.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList1);//添加內容到集合中}else if (userid.equals("200")){arrayList2.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList2);//添加內容到集合中}else if (userid.equals("300")){arrayList3.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList3);//添加內容到集合中}else if (userid.equals("至尊寶")){arrayList4.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList4);//添加內容到集合中} else if (userid.equals("紫霞仙子")) {arrayList5.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList5);//添加內容到集合中}else if (userid.equals("菩提老祖")){arrayList6.add(message);//把message添加到對應的集合中offLineDb.put(userid,arrayList6);//添加內容到集合中}}

4、如果用戶不在線我們就調用添加方法，把信息存入集合中

else if (message.getMesType().equals(MessageType.MESSAGE_FILE_MES)){//MessageType.MESSAGE_FILE_MES 文件消息(發送文件)類型//根據message獲取getter id,然后在得到對應線程ServerConnectClientThread serverConnectClientThread =ManageClientThreads.getServerConnectClientThread(message.getGetter());if (serverConnectClientThread == null) {//如果用戶不在線System.out.println("用戶不在線,文件消息存到了offLineDb集合中");//調用方法把message內容存到數組中ManageClientThreads.addClientOffLineDb(message.getGetter(),message);} else {System.out.println("用戶在線文件直接轉發");//根據getter id 獲取到對應的線程,將message對象轉發//代碼解讀:從管理線程的集合中通過message.getGetter()得到對應的線程//在通過線程得到socket,在得到 getOutputStream() 輸出流對象,// 最后賦給對象輸出流oosObjectOutputStream oos =new ObjectOutputStream(serverConnectClientThread.getSocket().getOutputStream());//得到對應socket的對象輸出流,將message對象轉發給指定的客戶端oos.writeObject(message);}

5、判斷存儲離線消息的集合中是否有剛剛登錄用戶的消息如果有就轉發給他，并把離線消息從集合中刪除。

//查找消息集合中是否有u.getUserId() 對應 Message 內容ArrayList clientOffLineDb = ManageClientThreads.getClientOffLineDb(u.getUserId());if (clientOffLineDb != null){//取出ArrayList數組中的messageIterator<Message> iterator = clientOffLineDb.iterator();//迭代器while (iterator.hasNext()) {Message message1 = iterator.next();//獲取對應內容System.out.println(message1);//得到線程對應的輸出流 并賦給對象輸出流ObjectOutputStream oos1 =new ObjectOutputStream(ManageClientThreads.getServerConnectClientThread(u.getUserId()).getSocket().getOutputStream());oos1.writeObject(message1);//把消息內容回發ManageClientThreads.removeClientOffLineDb(message1.getGetter());//回發成功把消息內容從數組中移除System.out.println("刪除了集合中暫存的消息內容");}}

這里只寫了擴展離線接收消息/文件的代碼，實現了一個用戶可以對多個離線用戶發送任意數量的離線消息或文件，如果離線用戶上線后接收的所有關于該用戶的離線文件則會通過服務器轉發給他，并從儲存離線文件的集合中刪除。

通過這種寫法的好處是不用修改客戶端的代碼，只需要在服務器端進行修改，但是不好之處在于代碼冗余度過高，如果有更好的思路希望能與大家交流一下。

效果演示:

登錄100號用戶給200號用戶發送離線消息，200號用戶登錄成功自動讀取離線消息并顯示

總結

以上是生活随笔為你收集整理的韩顺平Java:qq项目离线发送接收消息/文件扩展的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。