即使在我的工作管理器中连接到互联网，数据快照也不会更新

Question

通过调试，我可以看到它输入了所有这些，但snapshot有一个旧值。我在firebase数据库中启用了持久性。发生了什么？

这是我的工人阶级客栈代码，我在共享首选项中保存了一些数据。但例如，它输入ref1，但snapshot具有旧值。

public class Manager extends Worker {

    FirebaseDatabase database = FirebaseDatabase.getInstance();

    public Manager(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
    }

    ValueEventListener v1, v2, v3;



    @NonNull
    @Override
    public Result doWork() {

        boolean flag = getInputData().getBoolean("flag", false);

        CountDownLatch latch;

        if (isConnectedToWifi() || flag)
            latch = new CountDownLatch(3);
        else
            latch = new CountDownLatch(1);

        DatabaseReference ref1 = database.getReference("BASE/previous");
        ref1.addValueEventListener(v1 = new ValueEventListener() {
            @Override
            public void onDataChange(@NonNull DataSnapshot snapshot) {
                if (snapshot.exists()) {
                    ...
                }
                latch.countDown();
            }

            @Override
            public void onCancelled(@NonNull DatabaseError error) {
                //
                latch.countDown();
            }
        });


        DatabaseReference ref2 = null, ref3 = null;

        if (isConnectedToWifi() || flag) {


            ref2 = FirebaseDatabase.getInstance().getReference("BASE/syntelestes");
            ref2.addValueEventListener(v2 = new ValueEventListener() {
                @Override
                public void onDataChange(@NonNull DataSnapshot snapshot) {
                    if (snapshot.exists()) {
                        ...
                    }
                    latch.countDown();
                }

                @Override
                public void onCancelled(@NonNull DatabaseError error) {
                    //
                    latch.countDown();
                }
            });


            ref3 = FirebaseDatabase.getInstance().getReference("BASE/food_list");
            ref3.addValueEventListener(v3 = new ValueEventListener() {
                @Override
                public void onDataChange(@NonNull DataSnapshot snapshot) {
                    if (snapshot.exists()) {

                        ...
                    }
                    latch.countDown();
                }

                @Override
                public void onCancelled(@NonNull DatabaseError error) {
                    //
                    latch.countDown();
                }
            });

        }


        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        if (v1 != null) {
            ref1.removeEventListener(v1);
        }

        if (v2 != null && ref2 != null) {
            ref2.removeEventListener(v2);
        }

        if (v3 != null && ref3 != null) {
            ref3.removeEventListener(v3);
        }

        return Result.success();
    }

    public boolean isConnectedToWifi() {
        ConnectivityManager connManager = (ConnectivityManager) getApplicationContext().getSystemService(Context.CONNECTIVITY_SERVICE);
        NetworkInfo mWifi = connManager.getNetworkInfo(ConnectivityManager.TYPE_WIFI);
        return mWifi.isConnected();
    }

是否不需要查看细节（数据输入，…，工人内部工作等）。

Answer 1

如果已启用磁盘持久性，并且本地缓存中存储了一个值，则向addValueEventListener注册的侦听器的onDataChange将被调用两次：

1. 立即使用本地缓存中的当前值

没有办法改变addValueEventListener的这种行为。跳过#1

如果您想从服务器获取值，并且仅在服务器不可用时回退到磁盘缓存，请考虑使用更新的get（）操作来执行此操作。