当前位置: 首页 > 知识库问答 >
问题:

我在创建聊天应用程序时获得了ConcurrentModificationException

宋望
2023-03-14
  // private List<String> stringList; Declaration at top 
    stringList = new ArrayList<>();
    firebaseUser = FirebaseAuth.getInstance().getCurrentUser();

    databaseReference = FirebaseDatabase.getInstance().getReference("BaatCheet/Chats/");
    databaseReference.addValueEventListener(new ValueEventListener() {
        @Override
        public void onDataChange(@NonNull DataSnapshot dataSnapshot) {
            //userModelList.clear();
            for (DataSnapshot dataSnapshot1 : dataSnapshot.getChildren()) {
                MessageModel messageModel = dataSnapshot1.getValue(MessageModel.class);

                if (messageModel.getSender().equals(firebaseUser.getUid())){
                  stringList.add(messageModel.getReceiver());
                }
                if (messageModel.getReceiver().equals(firebaseUser.getUid())){
                    stringList.add(messageModel.getSender());
                }
            }
            readChat();
        }
        @Override
        public void onCancelled(@NonNull DatabaseError databaseError) {
        }
    });
  private void readChat() {

    userModelList = new ArrayList<>();
    databaseReference = FirebaseDatabase.getInstance().getReference("BaatCheet/Users/");

    databaseReference.addValueEventListener(new ValueEventListener() {
        @Override
        public void onDataChange(@NonNull DataSnapshot dataSnapshot) {
            userModelList.clear();
            for (DataSnapshot dataSnapshot1 : dataSnapshot.getChildren()){
                UserModel userModel = dataSnapshot1.getValue(UserModel.class);

                for (String id: stringList){
                    if (userModel.getId().equals(id)){
                        if (userModelList.size() !=0){
                            for (UserModel userModel1 : userModelList){
                                if (!userModel.getId().equals(userModel1.getId())){
                                    userModelList.add(userModel);
                                    Log.d("DataAdded",userModel.getId());
                                } // If the existing list don't have same value for sender and reciever
                            } // end of inner userModel
                        } else {
                            userModelList.add(userModel);
                            Log.d("DataAdded",userModel.getId());
                        } // end of else
                    }   // end of userModel id equals string id
                }   // end of String is loop
            }   // end of DataSnapshot loop

            usersAdapter = new UsersAdapter(userModelList);
            recyclerView.setAdapter(usersAdapter);


        } // end of onDataChange

        @Override
        public void onCancelled(@NonNull DatabaseError databaseError) {
        }
    });
}// end of readChat()

结果将是最近聊天的RecycerView,这些聊天包含发送者或接收者相互发送的消息。

共有1个答案

史骏祥
2023-03-14

在下面的代码片段中:

for (UserModel userModel1 : userModelList){
   if (!userModel.getId().equals(userModel1.getId())){
        userModelList.add(userModel);
        Log.d("DataAdded",userModel.getId());
    } // If the existing list don't have same value for sender and reciever
} //

您在迭代userModelList时正在修改userModelList。这是不允许的,这是ConcurrentModificationException的原因。

简化逻辑的方法很少,最简单(尽管不是最好的)是将这个foreach循环转换为一个简单的for i循环。

for (int i = 0; i< userModelList.size(); i++) {
    UserModel userModel1 = userModelList.get(i);
    if (!userModel.getId().equals(userModel1.getId())){
       userModelList.add(userModel);
       Log.d("DataAdded",userModel.getId());
    } // If the existing list don't have same value for sender and reciever
} //
 类似资料:
  • 我正在尝试使用node.js、socket.io和express制作一个简单的聊天应用程序。但是,如果我单击main.jade文件中的send按钮,页面会刷新,并且不会出现任何消息。我在Firebug中也遇到这个错误: 加载页面时,与ws:/127.0.0.1:3000/socket.io/?eio=2&transport=websocket&sid=d_hnmpdxhed-j7lraaah的连接

  • 但我发现棘轮棘轮网络,我相信这是使用网络插座。 有人知道第一个和第二个选项的优点吗?第一个选项(使用ajax)是一个好的选项吗?

  • 问题内容: 我想知道为数千名用户编写聊天应用程序的正确方法是什么。 我只是感到困惑,我如何才能每秒使用AJAX或更少的方法来对服务器执行ping操作,并检查MySQL中是否有新记录等,并且服务器负载可以接受。 我目前正在考虑使用jQuery,PHP和MySQL进行编码。 请指教。您的帮助将不胜感激。 问题答案: 客户端 对于需要轮询服务器的任何程序,我建议使用WebSockets。 我写了一个非常

  • 我正在使用XMPP在app引擎上编写一个聊天应用程序。我的想法是允许用户互相聊天。我可以将消息发送到google talk帐户,方法是将登录的用户删除地址的@gmail.com部分,并将其替换为@appid.appspotchat.com)。例如,如果登录的用户是bob@gmail.com,则用于发送的jid将是bob@appid.appspotchat.com)。然后,您可以将消息发送到goog

  • 现在我们已经熟悉了Socket.IO,让我们编写一个聊天应用程序,我们可以用它在不同的聊天室聊天。 我们将允许用户选择用户名并允许他们使用它们进行聊天。 首先,让我们设置我们的HTML文件来请求用户名 - <!DOCTYPE html> <html> <head> <title>Hello world</title> </head> <script src = "/s

  • 问题内容: 在我目前正在从事的项目中,我们需要开发一个Web聊天应用程序,而不是一个非常复杂的聊天,仅是一种将两个人联系起来谈论一个非常具体的话题的方式,我们不需要任何身份验证对于这两个用户之一,我们不必支持表情符号,头像或类似的东西。 一些项目成员建议我们可以通过BOSH使用XMPP,我说这就像试图用船网抓鱼,并提出了一种更简单的方法,例如简单的Ajax / MySQL网络聊天,但是我们担心性能