如何刷新分页3库中的页码

如何解决如何刷新分页3库中的页码

我正在使用分页3在回收器视图中加载一些数据。我从服务器获取数据，然后将其存储在本地数据库中。 这是我的DAO界面：

@Dao
interface TicketDAO {


    @Insert(onConflict = OnConflictStrategy.REPLACE)
    fun insert(model: TicketListModel)


    @Query("SELECT * FROM ticket_list ORDER BY lastModifyDate DESC,lastModifyTime DESC")
    fun getTickets(): PagingSource<Int,TicketListModel>


    @Query("delete from ticket_list")
    fun deleteall()


}

我假定此接口为我的数据源类。由于我也从服务器获取数据，因此我使用了这样的远程中介器（顺便说一下，我使用凌空协议从服务器获取数据）：

@ExperimentalPagingApi
class TicketRemoteMediator(val ticketDatabase: TicketDAO,val context: Context) :
    RemoteMediator<Int,TicketListModel>() {

    private val scope = Coroutinescope(dispatchers.Default)
    private var page = 0
    private var reachedEnd = false
    override suspend fun load(
        loadType: LoadType,state: PagingState<Int,TicketListModel>
    ): MediatorResult {
        return try {
            fetchData(page = page)
            page += 1
            Log.i("Log","page is $page")
            MediatorResult.Success(endOfPaginationReached = reachedEnd)
        } catch (e: Exception) {
            page -= 1
            MediatorResult.Error(e)
        }

    }

    private fun fetchData(page: Int) {
        val request = object : JsonObjectRequest(
            Method.GET,Address().getTicketAPI(page),null,Response.Listener {
                reachedEnd = true
                val info = it.getJSONArray("results")
                for (i in 0 until info.length()) {
                    val data = info.getJSONObject(i)
                    scope.launch {
                        async(dispatchers.Default,Coroutinestart.DEFAULT,block = {
                            ticketDatabase.insert(
                                TicketListModel(
                                    subject = data.getString("subject"),status = data.getString("status"),)
                            reachedEnd = false
                        }).await()
                    }
                }

            },Response.ErrorListener {
                this.page -= 1
                reachedEnd = false
                try {
                    Log.i("Log","error in ticket remoteMediator ${String(it.networkResponse.data,Charsets.UTF_8)}")
                }catch (e:Exception){
                    Log.i("Log","error in ticket mediator $it")
                }

            }
        ) {
            @Throws(AuthFailureError::class)
            override fun getHeaders(): MutableMap<String,String> {
                val token = HashMap<String,String>()
                token["Authorization"] =
                    "Bearer ${Config().accesstoken}"
                return token
            }
        }
        request.retryPolicy = DefaultRetryPolicy(10000,5,DefaultRetryPolicy.DEFAULT_BACKOFF_MULT)
        val queue = Volley.newRequestQueue(context)
        queue.add(request)
    }
}

并使用我的视图模型类使用数据，如下所示：

    val isLoading = mutablelivedata<Boolean>()

    @ExperimentalPagingApi
    val tickets= Pager(
        config = PagingConfig(pageSize =5),remoteMediator = TicketRemoteMediator(ticketDatabase = database,context = context)
    ) {
        database.getTickets()

    }.liveData.cachedIn(viewmodelScope).also {
        isLoading.value = false
    }

并且我的片段中有这段代码：

            viewmodel.tickets.observe(viewLifecycleOwner,Observer {
                viewLifecycleOwner.lifecycleScope.launch {
                    adapter.submitData(it)
                }
            })

回收站视图适配器的哪个部分是：

class Ticketlistadapter :  PagingDataAdapter<TicketListModel,Ticketlistadapter.ViewHolder>(
   diffCallback =      object : DiffUtil.ItemCallback<TicketListModel>() {
       override fun areItemsTheSame(oldItem: TicketListModel,newItem: TicketListModel): Boolean {
           return oldItem.ticket_id == newItem.ticket_id
       }
       override fun areContentsTheSame(
           oldItem: TicketListModel,newItem: TicketListModel
       ): Boolean {
           return oldItem == newItem
       }

   }
) {

...
}

现在，我有两个问题：

首先： 我的用户有时想刷新列表。使用滑动刷新。 因此，我为此设置了以下代码行，但没有任何反应：

        binding.refresh.setonRefreshListener {
            database.getTickets().invalidate()
        }

第二： 即使用户尚未滚动，来自服务器的大量分页库请求也很多。实际上，当我登录时，我看到有20多个请求发送到服务器，而在1或2个请求之后，所有信息都可以从服务器中获取。

我该如何解决这些问题？

解决方法

刷新很容易，您只需要在适配器上调用refresh()

binding.refresh.setOnRefreshListener{
    pagingAdapter.refresh()
}

至于有多个请求，这可能取决于您对pageSize给予的PagingConfig。如果您查看其中的其他参数，您会发现initialLoadSize的默认值是pageSize的三倍。这意味着它将在满意之前尝试加载pageSize * 3个项目。 Address().getTicketAPI(page)

返回了多少项目

更新：

我刚刚注意到，您的load方法始终假定我们在实际调用下一页时也尝试加载下一页，以刷新和加载上一页。 loadType参数决定了我们要加载的方向。

以下是您的加载方法应为什么样的示例

val nextPage = when (loadType) {
    LoadType.REFRESH -> 0 // we're refreshing so just reset the page
    LoadType.PREPEND -> return MediatorResult.Success(endOfPaginationReached = true) // shouldn't need to prepend
    LoadType.APPEND -> {
        // work out the next page number
        page + 1
    }

return try {
     fetchData(page = nextPage)
     Log.i("Log","page is $nextPage")
     MediatorResult.Success(endOfPaginationReached = reachedEnd)
} catch (e: Exception) {
     MediatorResult.Error(e)
}