从服务器进入RecyLerview时,实时更新数据



我从Websockets获得JSON并显示在Recyler View中。如何从WebSocket获取数据时如何实时更新列表?

我的Websocket类

 public final class EchoWebSocketListener extends WebSocketListener {
    private static final int NORMAL_CLOSURE_STATUS = 1000;
    private static final String TAG = "DashBoardScreen.this";
    @Override
    public void onOpen(WebSocket webSocket, Response response) {
        super.onOpen(webSocket, response);

最初建立连接时,我将一些文本发送给服务器

  webSocket.send(builder.toString());
    }
    @Override
    public void onMessage(WebSocket webSocket, String text) {
        super.onMessage(webSocket, text);

在返回服务器中向我发送数据

 output(text);
    }
    @Override
    public void onMessage(WebSocket webSocket, ByteString bytes) {
        super.onMessage(webSocket, bytes);
    }
    @Override
    public void onClosing(WebSocket webSocket, int code, String reason) {
        super.onClosing(webSocket, code, reason);
        Log.d(TAG, "onClosing: ");
    }
    @Override
    public void onClosed(WebSocket webSocket, int code, String reason) {
        super.onClosed(webSocket, code, reason);
        Log.d(TAG, "onClosed: ");
    }
    @Override
    public void onFailure(WebSocket webSocket, Throwable t,Response response) {
        super.onFailure(webSocket, t, response);
        Log.d(TAG, "onFailure: ");
    }
}

输出方法

 private void output(final String text) {
 runOnUiThread(new Runnable() {
            @Override
            public void run() {
             *parsing json inside recyler view*
                    try {
                        JSONObject object = new JSONObject(text);
                        StringBuilder builder = new StringBuilder();
                        if (object.getBoolean("status")) {
                            JSONArray jsonArray = object.getJSONArray("events");
                            for (int i = 0; i < jsonArray.length(); i++) {
                                JSONObject values = jsonArray.getJSONObject(i);
                                final EventsDataModel dataModel = new EventsDataModel(
                                        values.getString("service_Room_Number"),
                                        values.getString("service_Name"),
                                        values.getString("service_AssignedTo"),
                                        values.getString("service_ID")
                                );                       
                                eventsDataModels.add(dataModel);
                                adapter = new EventListAdapter(eventsDataModels, context);
                                eventRecyclerView.setAdapter(adapter);
                                adapter.notifyDataSetChanged(); 

如何确切地notifydatasetchanged()起作用?

                            }
                        } else Toast.makeText(context, "No Events", Toast.LENGTH_SHORT).show();
                        System.out.println(builder.append(object.getString("status")));
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
            }
        });
    }

每当您的datamodel拥有新数据

eventsDataModels.add(dataModel); adapter = new EventListAdapter(eventsDataModels, context); eventRecyclerView.setAdapter(adapter);

如果您执行上述操作并执行adapter.notifyDataSetChanged();将通知适配器新数据已到达,并且必须使用新的Datamodel更新回收道。

最新更新