具有 CustomAttributes 的 PubSub - 未调用接收器函数，但出现 json 解析异常

Question

Google 云和 PubSub 服务。

我在下面的示例代码行中实现了一个简单的 CustomAttributeReceiver

https://github.com/googleapis/java-pubsub/blob/master/samples/snippets/src/main/java/pubsub/PublishWithCustomAttributesExample.java

我怎么会遇到以下异常

com.google.gson.JsonSyntaxException: java.lang.IllegalStateException: 应为 STRING 但 BEGIN_OBJECT 位于路径 $ at com.google.gson.Gson.fromJson(Gson.java:944) at com.google.gson.Gson.fromJson(Gson.java:1003) 在 com.google.cloud.functions.invoker.NewBackgroundFunctionExecutor$TypedFunctionExecutor.serviceLegacyEvent(NewBackgroundFunctionExecutor.java:257) 在 com.google.cloud.functions.invoker.NewBackgroundFunctionExecutor.serviceLegacyEvent(NewBackgroundFunctionExecutor.java:343) 在

有人可以阐明我在这里缺少的东西吗？

发布方

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

import com.google.api.core.ApiFuture;
import com.google.cloud.pubsub.v1.Publisher;
import com.google.protobuf.ByteString;
import com.google.pubsub.v1.PubsubMessage;
import com.google.pubsub.v1.TopicName;
import PubSubMessage;


            TopicName topicName = TopicName.of(projectId, topicId);
        System.out.println("informListenersAboutSucessfulRegisteration=" + topicName);
        Publisher publisher = null;
        try {
            publisher = Publisher.newBuilder(topicName).build();
            PubSubMessage newUserRegisterMsg = new PubSubMessage();
            Map<String, String> attributes = new HashMap<String, String>();
            attributes.put(PubSubMessage.newUserLanguage, newUserLanguage);
            newUserRegisterMsg.setAttributes(attributes);
            ByteString data = ByteString.copyFromUtf8("NewUserRegisteration");
            PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).putAllAttributes(attributes).build();
            ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
            String messageId = messageIdFuture.get();
            System.out.println("Published message ID: " + messageId);
        } catch (Exception e) {
            Logger.getLogger(PubSubMessenger.name).log(Level.SEVERE, "Exception while publishing message", e);
        } finally {
            if (publisher != null) {
                publisher.shutdown();
                publisher.awaitTermination(1, TimeUnit.MINUTES);
            }
        }

接收端

    import java.nio.charset.StandardCharsets;
    import java.util.Base64;
    
    import com.google.cloud.functions.BackgroundFunction;
    import com.google.cloud.functions.Context;
    import PubSubMessage;

    
public class SendEmailFromSendGrid implements BackgroundFunction<PubSubMessage> {
    public SendEmailFromSendGrid() {
    }

    public void accept(PubSubMessage message, Context context) throws Exception {
        System.out.println("invoked accept");
        String name = "World";
        if (message != null && message.getData() != null) {
            name = new String(Base64.getDecoder().decode(message.getData().getBytes(StandardCharsets.UTF_8)),
                    StandardCharsets.UTF_8);
        }
        System.out.println(String.format("Hello %s!", name));
        return;
    }
}

PubSubMessage 定义

    import java.util.Map;

    public class PubSubMessage {

    public static final String newUserLanguage = "userLanguage";

    private String data;
    private Map<String, String> attributes;
    private String messageId;
    private String publishTime;

    public String getData() {
        return data;
    }

    public void setData(String data) {
        this.data = data;
    }

    public Map<String, String> getAttributes() {
        return attributes;
    }

    public void setAttributes(Map<String, String> attributes) {
        this.attributes = attributes;
    }

    public String getMessageId() {
        return messageId;
    }

    public void setMessageId(String messageId) {
        this.messageId = messageId;
    }

    public String getPublishTime() {
        return publishTime;
    }

    public void setPublishTime(String publishTime) {
        this.publishTime = publishTime;
    }
}

谢谢你

Answer 1

此回答由@user1241724在评论区提供：

Redid the whole exercise and it is working now. Only difference is added default constructor in PubSubMessage.

具有 CustomAttributes 的 PubSub - 未调用接收器函数，但出现 json 解析异常

PubSub with CustomAttributes - Receiver function is not invoked but a json parse exception is coming up

google-cloud-platform

google-cloud-pubsub