Android RecyclerView实时快速更新实现及多设备更新显示错乱排查

先揪出代码里的关键问题 #

你的代码里有几个坑直接导致了数据串位：

1. 线程错误：MQTT消息回调一般跑在后台线程，你直接在这个线程里修改数据集、调用RecyclerView更新方法，线程不安全，很容易搞乱UI状态。
2. 数据引用处理不当：你直接修改LogData对象的now字段再塞回原列表，但RecyclerView的ViewHolder复用机制会让旧ViewHolder还拿着这个对象的引用，一复用就会显示错误数据。
3. 多线程并发修改数据：多个电表同时更新时，多个线程同时操作devices集合，数据状态会乱套。

针对性修复方案 #

1. 强制在主线程做UI和数据更新 #

Android规定UI操作必须在主线程，把所有更新逻辑包到runOnUiThread里：

private void updateDeviceStatus(final int index, final String mess) {
    // 切换到主线程再执行更新
    runOnUiThread(() -> {
        Device device = devices.get(index);
        String []d = mess.split(",");
        if (d.length>=device.model.log.size()){
            device.error = null;
            // 不直接修改原LogData，重新创建新列表
            List<LogData> updatedLogs = new ArrayList<>();
            for(int x=0; x<device.model.log.size(); x++){
                LogData oldData = device.model.log.get(x);
                // 用拷贝构造方法创建新的LogData，避免修改旧对象
                LogData newData = new LogData(oldData);
                newData.now = d[x];
                updatedLogs.add(newData);
            }
            device.model.log = updatedLogs;
        }else {
            device.error = "Error Log Data!";
        }
        // 创建新的Device对象替换旧的，保证数据不可变性
        Device updatedDevice = new Device(device);
        devices.set(index, updatedDevice);
        adapter.notifyItemChanged(index);
    });
}

2. 用不可变数据模式解决引用混乱 #

ViewHolder复用的时候，要是Device、LogData是可变对象，修改旧对象会让已绑定的ViewHolder跟着变。所以：

• 把Device和LogData改成不可变类：字段用final修饰，要修改数据就创建新对象，绝不直接修改原对象。
• 每次更新都替换集合里的旧对象，不让ViewHolder持有旧数据引用。

3. 换成ListAdapter（强烈推荐） #

ListAdapter自带DiffUtil，能自动识别真正变化的条目，只更新这些条目，既解决错乱问题又提升更新效率：

第一步：编写Diff回调类

public class DeviceDiffCallback extends DiffUtil.ItemCallback<Device> {
    @Override
    public boolean areItemsTheSame(@NonNull Device oldItem, @NonNull Device newItem) {
        // 用设备唯一ID判断是否为同一个条目（比如设备编号）
        return oldItem.deviceId.equals(newItem.deviceId);
    }

    @Override
    public boolean areContentsTheSame(@NonNull Device oldItem, @NonNull Device newItem) {
        // 对比所有显示相关的字段，不一致则触发更新
        return (oldItem.error == null ? newItem.error == null : oldItem.error.equals(newItem.error))
                && oldItem.model.log.equals(newItem.model.log);
    }
}

第二步：定义ListAdapter

public class DeviceAdapter extends ListAdapter<Device, DeviceAdapter.DeviceViewHolder> {
    public DeviceAdapter() {
        super(new DeviceDiffCallback());
    }

    @NonNull
    @Override
    public DeviceViewHolder onCreateViewHolder(@NonNull ViewGroup parent, int viewType) {
        View itemView = LayoutInflater.from(parent.getContext()).inflate(R.layout.item_device, parent, false);
        return new DeviceViewHolder(itemView);
    }

    @Override
    public void onBindViewHolder(@NonNull DeviceViewHolder holder, int position) {
        Device device = getItem(position);
        // 绑定数据到View，示例：holder.tvError.setText(device.error);
    }

    static class DeviceViewHolder extends RecyclerView.ViewHolder {
        // 定义控件示例
        TextView tvError;

        public DeviceViewHolder(@NonNull View itemView) {
            super(itemView);
            tvError = itemView.findViewById(R.id.tv_error);
            // 初始化其他控件
        }
    }
}

第三步：更新数据时提交新列表

private void updateDeviceStatus(final int index, final String mess) {
    runOnUiThread(() -> {
        // 先拷贝整个数据集，避免并发修改问题
        List<Device> newDevices = new ArrayList<>(devices);
        Device oldDevice = newDevices.get(index);
        String []d = mess.split(",");
        Device updatedDevice;

        if (d.length>=oldDevice.model.log.size()){
            List<LogData> updatedLogs = new ArrayList<>();
            for(int x=0; x<oldDevice.model.log.size(); x++){
                LogData oldLog = oldDevice.model.log.get(x);
                LogData newLog = new LogData(oldLog);
                newLog.now = d[x];
                updatedLogs.add(newLog);
            }
            // 创建新的Device对象
            updatedDevice = new Device(oldDevice.deviceId, oldDevice.model, updatedLogs, null);
        }else {
            updatedDevice = new Device(oldDevice.deviceId, oldDevice.model, oldDevice.model.log, "Error Log Data!");
        }

        newDevices.set(index, updatedDevice);
        // 提交新列表给ListAdapter
        adapter.submitList(newDevices);
        // 更新本地数据集
        devices = newDevices;
    });
}

4. 用线程安全集合防范并发问题 #

如果多个MQTT回调同时触发更新，把devices换成CopyOnWriteArrayList，它是线程安全的，每次修改都会拷贝整个列表，不会出现并发修改异常：

private List<Device> devices = new CopyOnWriteArrayList<>();

实时更新的优化小技巧 #

• 合并高频更新：如果某个设备短时间内收到多条消息，用Handler延迟100ms左右，把多次更新合并成一次，减少RecyclerView刷新次数。
• 避免滥用notifyDataSetChanged()：这个方法会刷新所有条目，效率低还容易出错，只用notifyItemChanged(index)或者ListAdapter的submitList。
• ViewHolder别存数据引用：绑定数据时直接把内容赋值给View，不要保存数据对象的引用，防止数据变化后View还显示旧内容。

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