为什么 JsonHttpContent 的输出是空的?
Why is JsonHttpContent's output empty?
我正在 Google App Engine (1.9.30) 上使用 Google Http 客户端库 (1.20) 向 Google 云消息传递 ( GCM)服务器。这是代码:
public static HttpRequestFactory getGcmRequestFactory() {
if (null == gcmFactory) {
gcmFactory = (new UrlFetchTransport())
.createRequestFactory(new HttpRequestInitializer() {
@Override
public void initialize(HttpRequest request) throws IOException {
request.getHeaders().setAuthorization(
"key=" + Config.get(Config.Keys.GCM_SERVER_API_KEY).orNull());
request.getHeaders().setContentType("application/json");
request.getHeaders().setAcceptEncoding(null);
}
});
}
return gcmFactory;
}
public static JsonFactory getJsonFactory() {
return jacksonFactory;
}
public static String sendGcmMessage(GcmDownstreamDto message) {
HttpRequestFactory factory = getGcmRequestFactory();
JsonHttpContent content = new JsonHttpContent(getJsonFactory(), message);
String response = EMPTY;
try {
HttpRequest req = factory.buildPostRequest(gcmDownstreamUrl, content);
log.info("req headers = " + req.getHeaders());
System.out.print("req content = ");
content.writeTo(System.out); // prints out "{}"
System.out.println(EMPTY);
HttpResponse res = req.execute(); // IOException here
response = IOUtils.toString(res.getContent());
} catch (IOException e) {
log.log(Level.WARNING, "IOException...", e);
}
return response;
}
现在 content.writeTo()
总是打印出空的 JSON。这是为什么?我究竟做错了什么? GcmDownstreamDto
class(使用Lombok生成getters和setters):
@Data
@Accessors(chain = true)
public class GcmDownstreamDto {
private String to;
private Object data;
private List<String> registration_ids;
private GcmNotificationDto notification;
public GcmDownstreamDto addRegistrationId(String regId) {
if (null == this.registration_ids) {
this.registration_ids = new ArrayList<>();
}
if (isNotBlank(regId)) {
this.registration_ids.add(regId);
}
return this;
}
}
近期目标是生成与(来自 Checking the validity of an API key)相同的响应:
api_key=YOUR_API_KEY
curl --header "Authorization: key=$api_key" \
--header Content-Type:"application/json" \
https://gcm-http.googleapis.com/gcm/send \
-d "{\"registration_ids\":[\"ABC\"]}"
{"multicast_id":6782339717028231855,"success":0,"failure":1,
"canonical_ids":0,"results":[{"error":"InvalidRegistration"}]}
我已经使用 curl
进行了测试,所以我知道 API 密钥是有效的,我只想在 Java 代码中做同样的事情来建立我的基础 classes.
sendGcmMessage()
被调用如下:
@Test
public void testGcmDownstreamMessage() {
GcmDownstreamDto message = new GcmDownstreamDto().addRegistrationId("ABC");
System.out.println("message = " + message);
String response = NetCall.sendGcmMessage(message);
System.out.println("Response: " + response);
}
感谢所有帮助。
发现了问题:这是 JacksonFactory().createJsonGenerator().searialize()
的工作方式(我期待它以 ObjectMapper
序列化的方式序列化)。这是 JsonHttpContent.writeTo()
的代码(来自 JsonHttpContent.java in google-http-java-client):
public void writeTo(OutputStream out) throws IOException {
JsonGenerator generator = jsonFactory.createJsonGenerator(out, getCharset());
generator.serialize(data);
generator.flush();
}
Jackson JsonGenerator
期望 key-value 配对(在 Java 中表示为 Map
),这在 JsonHttpContent
的构造函数签名中并不明显构造函数:JsonHttpContent(JsonFactory, Object)
.
因此,如果不是传递 GcmDownstreamDto
(如问题中所定义,这是 ObjectMapper
的工作方式),我将执行以下操作:
Map<String, Object> map = new HashMap<>();
List<String> idList = Arrays.asList("ABC");
map.put("registration_ids", idList);
一切正常,输出为:
{"registration_ids":["ABC"]}
所以请记住将 JsonHttpContent(JsonFactory, Object)
构造函数作为第二个参数传递给 Map<String, Object>
,一切都会按照您的预期进行。
您需要使用 @Key
:
注释 POJO 字段
import com.google.api.client.util.Key;
// ...
@Key private String to;
@Key private Object data;
@Key private List<String> registration_ids;
// ...
我正在 Google App Engine (1.9.30) 上使用 Google Http 客户端库 (1.20) 向 Google 云消息传递 ( GCM)服务器。这是代码:
public static HttpRequestFactory getGcmRequestFactory() {
if (null == gcmFactory) {
gcmFactory = (new UrlFetchTransport())
.createRequestFactory(new HttpRequestInitializer() {
@Override
public void initialize(HttpRequest request) throws IOException {
request.getHeaders().setAuthorization(
"key=" + Config.get(Config.Keys.GCM_SERVER_API_KEY).orNull());
request.getHeaders().setContentType("application/json");
request.getHeaders().setAcceptEncoding(null);
}
});
}
return gcmFactory;
}
public static JsonFactory getJsonFactory() {
return jacksonFactory;
}
public static String sendGcmMessage(GcmDownstreamDto message) {
HttpRequestFactory factory = getGcmRequestFactory();
JsonHttpContent content = new JsonHttpContent(getJsonFactory(), message);
String response = EMPTY;
try {
HttpRequest req = factory.buildPostRequest(gcmDownstreamUrl, content);
log.info("req headers = " + req.getHeaders());
System.out.print("req content = ");
content.writeTo(System.out); // prints out "{}"
System.out.println(EMPTY);
HttpResponse res = req.execute(); // IOException here
response = IOUtils.toString(res.getContent());
} catch (IOException e) {
log.log(Level.WARNING, "IOException...", e);
}
return response;
}
现在 content.writeTo()
总是打印出空的 JSON。这是为什么?我究竟做错了什么? GcmDownstreamDto
class(使用Lombok生成getters和setters):
@Data
@Accessors(chain = true)
public class GcmDownstreamDto {
private String to;
private Object data;
private List<String> registration_ids;
private GcmNotificationDto notification;
public GcmDownstreamDto addRegistrationId(String regId) {
if (null == this.registration_ids) {
this.registration_ids = new ArrayList<>();
}
if (isNotBlank(regId)) {
this.registration_ids.add(regId);
}
return this;
}
}
近期目标是生成与(来自 Checking the validity of an API key)相同的响应:
api_key=YOUR_API_KEY
curl --header "Authorization: key=$api_key" \
--header Content-Type:"application/json" \
https://gcm-http.googleapis.com/gcm/send \
-d "{\"registration_ids\":[\"ABC\"]}"
{"multicast_id":6782339717028231855,"success":0,"failure":1,
"canonical_ids":0,"results":[{"error":"InvalidRegistration"}]}
我已经使用 curl
进行了测试,所以我知道 API 密钥是有效的,我只想在 Java 代码中做同样的事情来建立我的基础 classes.
sendGcmMessage()
被调用如下:
@Test
public void testGcmDownstreamMessage() {
GcmDownstreamDto message = new GcmDownstreamDto().addRegistrationId("ABC");
System.out.println("message = " + message);
String response = NetCall.sendGcmMessage(message);
System.out.println("Response: " + response);
}
感谢所有帮助。
发现了问题:这是 JacksonFactory().createJsonGenerator().searialize()
的工作方式(我期待它以 ObjectMapper
序列化的方式序列化)。这是 JsonHttpContent.writeTo()
的代码(来自 JsonHttpContent.java in google-http-java-client):
public void writeTo(OutputStream out) throws IOException {
JsonGenerator generator = jsonFactory.createJsonGenerator(out, getCharset());
generator.serialize(data);
generator.flush();
}
Jackson JsonGenerator
期望 key-value 配对(在 Java 中表示为 Map
),这在 JsonHttpContent
的构造函数签名中并不明显构造函数:JsonHttpContent(JsonFactory, Object)
.
因此,如果不是传递 GcmDownstreamDto
(如问题中所定义,这是 ObjectMapper
的工作方式),我将执行以下操作:
Map<String, Object> map = new HashMap<>();
List<String> idList = Arrays.asList("ABC");
map.put("registration_ids", idList);
一切正常,输出为:
{"registration_ids":["ABC"]}
所以请记住将 JsonHttpContent(JsonFactory, Object)
构造函数作为第二个参数传递给 Map<String, Object>
,一切都会按照您的预期进行。
您需要使用 @Key
:
import com.google.api.client.util.Key;
// ...
@Key private String to;
@Key private Object data;
@Key private List<String> registration_ids;
// ...