如何基于AWS Amplify实现RecyclerView无限滚动与实时数据加载

你当前使用的默认ModelQuery.list查询存在固定返回条数上限（Amplify GraphQL单次查询默认最多返回1000条数据），未做游标分页、滚动触发加载、实时事件订阅逻辑，因此无法实现类社交平台的无限滚动信息流效果，可按以下步骤实现：

1. 实现游标分页查询逻辑 #

Amplify GraphQL原生支持基于游标（cursor）的分页能力，每次查询可指定单页返回条数，查询结果会携带下一页起始标记nextToken，基于这个标记逐页拉取数据即可。
首先定义分页相关全局状态变量：

// 单页加载条数，建议设置为20-30，平衡加载速度与请求频率
private final int PAGE_SIZE = 25;
// 下一页查询游标，初始为null代表拉取第一页数据
private String nextPageToken = null;
// 加载状态标记，避免重复触发分页请求
private boolean isDataLoading = false;
// 末页标记，标记是否已拉取完全部匹配数据
private boolean isAllDataLoaded = false;
// 你的RecyclerView适配器实例
private TodoRvAdapter todoAdapter;

封装通用分页加载方法：

private void fetchNextPage() {
    if (isDataLoading || isAllDataLoaded) return;
    isDataLoading = true;

    // 替换为你实际业务的查询条件
    ModelQuery<Todo> listQuery = ModelQuery.list(Todo.class, Todo.NAME.contains("first"));
    Amplify.API.query(
        listQuery,
        PAGE_SIZE,
        nextPageToken,
        response -> {
            // Amplify回调默认在后台线程，必须切主线程更新UI
            runOnUiThread(() -> {
                List<Todo> pageData = new ArrayList<>();
                for (Todo item : response.getData()) {
                    pageData.add(item);
                }
                // 更新分页游标：返回token为null即代表已经到最后一页
                nextPageToken = response.getNextToken();
                isAllDataLoaded = nextPageToken == null;
                // 新数据追加到适配器现有列表尾部，不要全量替换
                todoAdapter.appendItems(pageData);
                isDataLoading = false;
            });
        },
        error -> {
            Log.e("AmplifyInf", "分页查询失败", error);
            runOnUiThread(() -> isDataLoading = false);
        }
    );
}

2. 绑定RecyclerView滚动监听实现自动加载 #

给RecyclerView添加滚动监听器，在用户滑动到接近列表底部时提前触发下一页加载，避免用户看到加载等待：

// 初始化RecyclerView配置
RecyclerView todoRv = findViewById(R.id.rv_todo);
LinearLayoutManager layoutManager = new LinearLayoutManager(this);
todoRv.setLayoutManager(layoutManager);
todoAdapter = new TodoRvAdapter();
todoRv.setAdapter(todoAdapter);

// 添加滚动监听
todoRv.addOnScrollListener(new RecyclerView.OnScrollListener() {
    @Override
    public void onScrolled(@NonNull RecyclerView rv, int dx, int dy) {
        super.onScrolled(rv, dx, dy);
        // 仅处理向下滑动场景
        if (dy <= 0) return;
        int totalCount = layoutManager.getItemCount();
        int lastVisiblePos = layoutManager.findLastVisibleItemPosition();
        // 距离底部剩余3个item时提前触发加载，用户无感知
        if (!isDataLoading && !isAllDataLoaded && lastVisiblePos + 3 >= totalCount) {
            fetchNextPage();
        }
    }
});

// 页面首次进入加载第一页数据
fetchNextPage();

3. 接入实时数据更新 #

通过Amplify的订阅能力监听数据变更事件，有新增/修改/删除数据时实时同步到列表，实现信息流实时更新效果：

// 持有订阅实例，页面销毁时需要取消避免内存泄漏
private GraphQLSubscription<Todo> dataSubscription;

private void startRealtimeListen() {
    dataSubscription = Amplify.API.subscribe(
        // 监听Todo新建事件，可按需添加和查询一致的过滤条件
        ModelSubscription.onCreate(Todo.class),
        startAck -> Log.i("AmplifyInf", "实时订阅连接成功"),
        createEvent -> {
            Todo newItem = createEvent.getData();
            runOnUiThread(() -> {
                // 新增内容插入到列表顶部，模拟信息流新内容推送
                todoAdapter.insertItemToTop(newItem);
            });
        },
        // 可额外扩展更新、删除事件监听，同步修改列表对应项
        // updateEvent -> { 处理数据更新逻辑 },
        // deleteEvent -> { 处理数据删除逻辑 },
        error -> Log.e("AmplifyInf", "订阅连接异常", error),
        () -> Log.i("AmplifyInf", "订阅已断开")
    );
}

@Override
protected void onDestroy() {
    super.onDestroy();
    // 页面销毁时取消订阅
    if (dataSubscription != null) dataSubscription.cancel();
}
// 在onCreate中调用startRealtimeListen()启动订阅即可

优化注意事项 #

• 适配器更新数据时避免全量调用notifyDataSetChanged()，追加数据用notifyItemRangeInserted()、顶部插入用notifyItemInserted(0)，列表动画更流畅
• 实现下拉刷新时，只需在刷新回调中重置nextPageToken = null、isAllDataLoaded = false、清空适配器数据，再调用fetchNextPage()即可
• 若查询条件会动态变化（如切换分类、修改搜索关键词），切换时和下拉刷新做相同的状态重置再重新拉取第一页即可
• 可在列表尾部添加加载中、加载失败、没有更多数据的footer项，交互体验更好

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