如何从其他类更新RecyclerView？多类交互消息同步实现问询

嘿，这个场景我在实际开发中碰过好多次了，给你拆解一套清晰可落地的实现流程，分步骤来：

首先得明确几个组件的协作逻辑：Server在后台子线程蹲消息，收到后找到对应的Contact实例塞消息，然后通知UI层（Chat Activity）更新RecyclerView。这里的关键坑点是子线程绝对不能直接更新UI，所以必须搞定线程间通信，同时要保证数据的一致性——Server和Chat Activity操作的得是同一个Contact对象。

1. 先定义好Contact数据模型 #

Contact要负责存储聊天记录，还要保证线程安全（毕竟子线程和UI线程都会碰它）：

public class Contact {
    private final String contactId;
    // 用ArrayList加同步锁，或者直接用CopyOnWriteArrayList（线程安全的集合）
    private final List<Message> messages = new ArrayList<>();

    public Contact(String contactId) {
        this.contactId = contactId;
    }

    // 添加消息时加同步锁，避免多线程并发修改出问题
    public synchronized void addMessage(Message message) {
        messages.add(message);
    }

    // 返回消息列表的副本，防止外部直接修改原集合
    public synchronized List<Message> getMessages() {
        return new ArrayList<>(messages);
    }

    public String getContactId() {
        return contactId;
    }
}

// 顺带定义下Message模型
public class Message {
    private String content;
    private long timestamp;
    private boolean isSentByMe;
    private String targetContactId;

    // 构造方法、getter/setter
}

2. Server子线程的消息接收与分发 #

Server在子线程里监听网络，收到消息后解析出目标联系人ID，找到对应的Contact实例，调用addMessage方法。这里要注意，Contact实例最好存在全局的管理类里（比如ContactManager单例），或者通过ViewModel持有，确保Server和Chat Activity拿到的是同一个对象：

public class ServerThread extends Thread {
    private final ContactManager contactManager;
    private final ChatViewModel chatViewModel;

    public ServerThread(ContactManager contactManager, ChatViewModel chatViewModel) {
        this.contactManager = contactManager;
        this.chatViewModel = chatViewModel;
    }

    @Override
    public void run() {
        // 模拟持续监听网络消息
        while (!isInterrupted()) {
            Message receivedMsg = receiveNetworkMessage();
            String targetId = receivedMsg.getTargetContactId();
            
            // 找到目标Contact
            Contact targetContact = contactManager.getContactById(targetId);
            if (targetContact != null) {
                targetContact.addMessage(receivedMsg);
                // 通知ViewModel更新UI（这里用ViewModel+LiveData的方案）
                chatViewModel.notifyContactUpdated(targetContact);
            }
        }
    }

    // 实际网络接收逻辑，这里简化模拟
    private Message receiveNetworkMessage() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new Message("对方发来的消息", System.currentTimeMillis(), false, "contact_001");
    }
}

// 全局Contact管理类示例
public class ContactManager {
    private static ContactManager instance;
    private final Map<String, Contact> contactMap = new HashMap<>();

    private ContactManager() {}

    public static synchronized ContactManager getInstance() {
        if (instance == null) {
            instance = new ContactManager();
        }
        return instance;
    }

    public void addContact(Contact contact) {
        contactMap.put(contact.getContactId(), contact);
    }

    public Contact getContactById(String contactId) {
        return contactMap.get(contactId);
    }
}

3. 用ViewModel+LiveData搞定线程间通信（最推荐的方案） #

ViewModel负责持有Contact数据，LiveData自动处理线程切换，还能感知Activity生命周期，完全不用担心内存泄漏：

import androidx.lifecycle.MutableLiveData;
import androidx.lifecycle.ViewModel;

public class ChatViewModel extends ViewModel {
    // 持有当前聊天的Contact的LiveData
    private final MutableLiveData<Contact> currentContactLiveData = new MutableLiveData<>();

    // 设置当前要展示的Contact
    public void setCurrentContact(Contact contact) {
        currentContactLiveData.setValue(contact);
    }

    // 供Server调用，通知Contact更新了
    public void notifyContactUpdated(Contact updatedContact) {
        // postValue可以在子线程调用，自动切换到主线程更新UI
        currentContactLiveData.postValue(updatedContact);
    }

    // 给Activity提供观察的LiveData
    public MutableLiveData<Contact> getCurrentContactLiveData() {
        return currentContactLiveData;
    }
}

4. Chat Activity里的RecyclerView展示与更新 #

在Activity里初始化RecyclerView，观察ViewModel的LiveData，一旦数据变化就更新适配器，还要记得滚动到底部显示最新消息：

import androidx.appcompat.app.AppCompatActivity;
import androidx.lifecycle.ViewModelProvider;
import androidx.recyclerview.widget.LinearLayoutManager;
import androidx.recyclerview.widget.RecyclerView;

import android.os.Bundle;

public class ChatActivity extends AppCompatActivity {
    private ChatAdapter chatAdapter;
    private ChatViewModel chatViewModel;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_chat);

        // 初始化ViewModel
        chatViewModel = new ViewModelProvider(this).get(ChatViewModel.class);

        // 获取当前聊天的Contact（比如从Intent传过来contactId）
        String contactId = getIntent().getStringExtra("CONTACT_ID");
        Contact currentContact = ContactManager.getInstance().getContactById(contactId);
        chatViewModel.setCurrentContact(currentContact);

        // 初始化RecyclerView
        RecyclerView recyclerView = findViewById(R.id.rv_chat);
        chatAdapter = new ChatAdapter(currentContact.getMessages());
        recyclerView.setAdapter(chatAdapter);
        recyclerView.setLayoutManager(new LinearLayoutManager(this));

        // 观察LiveData，数据变化时更新UI
        chatViewModel.getCurrentContactLiveData().observe(this, updatedContact -> {
            chatAdapter.updateMessages(updatedContact.getMessages());
            // 滚动到底部，显示最新消息
            recyclerView.scrollToPosition(chatAdapter.getItemCount() - 1);
        });
    }
}

5. RecyclerView适配器实现 #

适配器要提供更新消息列表的方法，用notifyItemInserted比notifyDataSetChanged更高效：

import androidx.recyclerview.widget.RecyclerView;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.TextView;

import java.util.List;

public class ChatAdapter extends RecyclerView.Adapter<ChatAdapter.MessageViewHolder> {
    private List<Message> messages;

    public ChatAdapter(List<Message> messages) {
        this.messages = messages;
    }

    // 更新消息列表，只通知最后一条插入，提升性能
    public void updateMessages(List<Message> newMessages) {
        int oldSize = this.messages.size();
        this.messages = newMessages;
        if (newMessages.size() > oldSize) {
            notifyItemInserted(newMessages.size() - 1);
        } else {
            notifyDataSetChanged(); // 极端情况（比如消息被删除）用这个
        }
    }

    @Override
    public MessageViewHolder onCreateViewHolder(ViewGroup parent, int viewType) {
        // 根据消息是自己发的还是对方发的加载不同布局，这里简化成一个布局
        View view = LayoutInflater.from(parent.getContext())
                .inflate(R.layout.item_message, parent, false);
        return new MessageViewHolder(view);
    }

    @Override
    public void onBindViewHolder(MessageViewHolder holder, int position) {
        Message message = messages.get(position);
        holder.tvContent.setText(message.getContent());
        // 可以根据isSentByMe设置不同的对齐方式、背景色等
    }

    @Override
    public int getItemCount() {
        return messages.size();
    }

    static class MessageViewHolder extends RecyclerView.ViewHolder {
        TextView tvContent;

        public MessageViewHolder(View itemView) {
            super(itemView);
            tvContent = itemView.findViewById(R.id.tv_message_content);
        }
    }
}

• 线程安全：Contact里的消息列表操作一定要加同步，或者用线程安全的集合（比如CopyOnWriteArrayList），避免多线程并发修改导致的异常。
• 内存泄漏：如果不用ViewModel+LiveData，而是用Handler或者runOnUiThread，一定要用WeakReference包裹Activity，防止Activity销毁后还被引用。
• 性能优化：更新RecyclerView时尽量用notifyItemInserted而不是notifyDataSetChanged，减少UI重绘的范围。
• 消息持久化：如果需要重启App后保留聊天记录，还要把Contact的消息列表持久化到本地（比如Room数据库），Server收到消息后同时更新数据库和内存中的Contact。

内容的提问来源于stack exchange，提问作者mndv