我正在尝试使用以下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和数据,它工作正常。
有人能指导我解决这个问题吗?
发布于 2018-03-04 22:57:31
我会使用一个库来抽象其中的一些东西,比如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循环之外完成,因为它永远不会改变。
https://stackoverflow.com/questions/48943386
复制相似问题