Java使用REST API向Firebase实时数据库发送数据问题

Question

我正在尝试使用以下JAVA代码使用REST API将一些数据发送到Firebase实时数据库。

public void doWork() {
        consumer.subscribe(Collections.singletonList(this.topic));
        ConsumerRecords<String, String> records = consumer.poll(1000);
        for (ConsumerRecord<String, String> record : records) {
            System.out.println("Sending data: " + record.value() );

            //  https://testiosproject-6054a.firebaseio.com/users.json
         // 1. URL
            URL url;
            try {
                url = new URL("https://testiosproject-1234a.firebaseio.com/users.json");

                // 2. Open connection
                HttpURLConnection conn = (HttpURLConnection) url.openConnection();              
                conn.setDoOutput(true);
                // 3. Specify POST method
                conn.setRequestMethod("POST");
                conn.setRequestProperty("Content-Type", "application/json");
                conn.setRequestProperty("Accept", "application/json");
                conn.connect();

                // Write data
                OutputStream os = conn.getOutputStream();
                OutputStreamWriter osw = new OutputStreamWriter(os, "UTF-8");
                osw.write(record.value());
                osw.flush();
                osw.close();

            } catch (MalformedURLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

以下是试图发送的数据：

Sending data: {"UserID":"101","UserAddress":"XYZ","UserAccount":"987","UserName":"Stella"}

但是，我没有在Firebase实时数据库控制台上收到此数据。我不确定这个问题的原因是什么？

我试过Postman客户端并尝试了相同的URL和数据，它工作正常。

有人可以指导我解决这个问题吗？

Answer 1

我会使用一个lib来抽象一些这样的东西，比如CXF（用于实际的HTTP东西）和Jackson（用于JSON处理）。代码将变得更加简单：

WebClient client = WebClient.create("https://testiosproject-1234a.firebaseio.com");
client.path("users.json");
client.type(MediaType.APPLICATION_JSON).accept(MediaType.APPLICATION_JSON)
Response r = client.post(record);
MyResponseClassIfAny b = r.readEntity(MyResponseClassIfAny .class);

改编自CXF Documentation。

请注意，大多数WebClient设置代码都可以（也可能应该）在fr循环之外完成，因为它永远不会改变。