JavaEE 和 Firebase admin sdk - setValueAsync 不将数据推送到实时 firebase

Question

我在 gradle 和 glassfish 服务器上构建的 intellij 上使用 firebase admin sdk 和 JavaEE。

我正在尝试将一个值推送到实时数据库，但遗憾的是我无法这样做。我已经在线搜索了数周，但一无所获。我还在 Whosebug 答案中遵循了一些解决方案，例如：但对我没有任何作用。

我已经阅读了很多 firebase admin sdk 会出现此类问题的原因，但我没有解决方案。

这是我的代码：

包装样品；

package sample;

import com.google.api.core.ApiFuture;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.firebase.FirebaseApp;
import com.google.firebase.FirebaseOptions;
import com.google.firebase.auth.FirebaseAuth;
import com.google.firebase.auth.FirebaseToken;
import com.google.firebase.auth.UserRecord;
import com.google.firebase.database.DataSnapshot;
import com.google.firebase.database.DatabaseReference;
import com.google.firebase.database.FirebaseDatabase;
import sample.model.FireBaseAuth;
import sample.model.FireBaseUtils;
import sample.model.Owner;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.lang.reflect.Method;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.HashMap;
import java.util.Map;
import java.util.Scanner;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

@WebServlet("/success")
public class SuccessServlet extends HttpServlet {

    public void init() throws ServletException {
        super.init();
        FireBaseUtils.initilizeFirebase();
    }

    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {

        String email = request.getParameter("email");
        String password  = request.getParameter("pass");

        //System.out.println(name);

        try{
            //a hashmap for the number of shopsOwned
            HashMap<String, String> shopsOwned = new HashMap<>();
            shopsOwned.put("shopName" , "shopName");

            //get the database instance and the database reference
            FirebaseDatabase database = FirebaseDatabase.getInstance();
            DatabaseReference ref = database.getReference("Business");

            DatabaseReference ownersRef = ref.child("Owners"); //further get the reference to the owners node

            //create a new owner with the values of the new user, using the Owner class
            Owner newOwner = new Owner("userRecord2.getUid()", "userRecord2.getDisplayName()",
                    "userRecord2.getPhoneNumber()", "userRecord2.getEmail()", shopsOwned);

            //create a hashmap of the users, in this case, just one user
            Map<String, Owner> users = new HashMap<>();
            users.put("userRecord2getPhoneNumber", newOwner); //add the new owner to the hashmap

            System.out.println("this is the user :" + newOwner.getFull_name());

            //push the new owner hashmap to the database reference
            ApiFuture<Void> future = ownersRef.push().setValueAsync(users);

            //Object o = future.get(8, TimeUnit.SECONDS);
            System.out.println(future.isDone());
            //System.out.println(future.isDone());

            request.getRequestDispatcher("success.jsp").forward(request, response);

        }catch(Exception e){e.printStackTrace();}



    }

    @Override
    public void doPost(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {

        doGet(request, response);

    }

}

任何想法将不胜感激。

编辑：我没有收到任何错误，webapp 运行正常但 firebase 的实时数据库没有更新

Answer 1

写入 Firestore（就像与大多数云 API 的交互）是异步发生的，并且在不同的线程上进行。当您调用 future.isDone() 时，操作尚未完成。

您需要添加一个在操作完成时调用的回调：

ApiFuture<Void> future = ownersRef.push().setValueAsync(users);
future.addCallback(future, new ApiFutureCallback<String>() {
    @Override
    public void onSuccess(String result) {
      System.out.println("Operation completed with result: " + result);
      System.out.println(future.isDone());
      request.getRequestDispatcher("success.jsp").forward(request, response);
    }

    @Override
    public void onFailure(Throwable t) {
      System.err.println("Operation failed with error: " + t);
    }

另见：

Firebase: Asynchronous Operations with Admin Java SDK

Answer 2

在返回请求线程之前，您需要等到 future 完成。否则无法保证更新完成，任何错误都会被默默丢弃。所以请尝试以下操作：

ApiFuture<Void> future = ownersRef.push().setValueAsync(users);
future.get();
request.getRequestDispatcher("success.jsp").forward(request, response);

JavaEE 和 Firebase admin sdk - setValueAsync 不将数据推送到实时 firebase

JavaEE and Firebase admin sdk - setValueAsync not pushing data to realtime firebase

java

firebase

firebase-realtime-database

firebase-admin