记录实现QQ模拟平台离线发送功能出现的BUG

• ConcurrentModificationException
• StreamCorruptedException: invalid stream header
• 代码

ConcurrentModificationException

1. 1. 1. 在对集合进行遍历时，错误使用remove方法；
2. 2. 2. 集合遍历是用迭代器进行的，因此应该使用iterator的方法来改动集合。

StreamCorruptedException: invalid stream header

1. 1. 1. 输出流对象数量和输入流对象数量应保持一致；换句话说，客户端一个输入流对象只接收一个信息，对应的，服务端一个输出流也只发送一个信息。

代码

这是该部分代码。

    //发送离线信息给目标用户
    public void send() {
        Iterator<String> iterator = hashMap.keySet().iterator();
        while (iterator.hasNext()) {
            //当目标用户上线时，把离线信息发送出去
            String target=iterator.next();
            Server01Socket s;
            if ((s =server01SocketManager.hm.get(target)) != null) {
                //取出目标用户的socket
                Socket socket=s.getSocket();
                try {

                    //将数组中所有messages发送给目标用户
                    for(int i=0;i<hashMap.get(target).size();i++){
                        //下面这行代码需放在循环里头
                        //这里的输出流对象的个数应该与客户端的输入流对象相对应
                        //即一个流对象只发送或接收一次
                        ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                        objectOutputStream.writeObject(hashMap.get(target).get(i));
                    }
                    //移除数据库已发送的数据
                    //一定要用iterator的remove()，不然会报ConcurrentModificationException
                    //原因：迭代器的expectedModCount和HashMap中的modCount的值不一致，系统会比较这两个值，不一致时抛出异常
                    iterator.remove();
                    //移除ArrayList中的messages
                    if(target.equals("至尊宝")){
                        list1.clear();
                    }
                    if(target.equals("紫霞仙子")){
                        list2.clear();
                    }
                    if(target.equals("猪八戒")){
                        list3.clear();
                    }
                    if(target.equals("唐僧")){
                        list4.clear();
                    }
                    if(target.equals("菩提老祖")){
                        list5.clear();
                    }

                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }