如何在 ignite-messaging lambda 函数的 Remotelisten

Question

我有一个监听主题的类（TopicListenerImp），我想从remoteListen函数获取消息，并将其作为参数提供给其他服务类中的另一个非静态函数。     @Component    public class TopicListenerImp implements TopicListener {      private NotificationService notificationService;      private SubscriptionRepository subscriptionRepository;      private SubscriptionRules subscriptionRules;      private NFInstancesService nfInstancesService;      private Ignite ignite;      public TopicListenerImp(          SubscriptionRules subscriptionRules,          NotificationService notificationService,          SubscriptionRepository subscriptionRepository,          Ignite ignite,          NFInstancesService nfInstancesService) {        this.subscriptionRules = subscriptionRules;        this.notificationService = notificationService;        this.subscriptionRepository = subscriptionRepository;        this.nfInstancesService = nfInstancesService;        this.ignite = ignite;      }      @Bean      public void startTopicListening() {        IgniteMessaging rmtMsg = ignite.message(ignite.cluster().forLocal());        rmtMsg.remoteListen(            "SUSPEND",            (nodeId, msg) -> {              notifyIfSubscriptionExist((String) msg); //here where I used the message that comes from topic              return true;             });      }      public void notifyIfSubscriptionExist(String msg) {        List<String> nfInstanceIdSubscriptionId = parseNfInstanceIdSubscriptionId(msg);        Optional<NFProfile> nfProfile =            nfInstancesService.getNFInstance(nfInstanceIdSubscriptionId.get(0));        Optional<SubscriptionData> subscriptionDataOptional =            subscriptionRepository.getSubscriptionData(nfInstanceIdSubscriptionId.get(1));            });      }但我收到以下错误；    Caused by: org.apache.ignite.binary.BinaryObjectException: Failed to serialize object etc.当我静态注入字段时，它起作用了。但是当我这样做时，IDE 会发出警告“不要从构造函数方法更新静态变量”。

Answer 1

RemoteListen采用一个谓词，该谓词将被序列化并通过网络发送到远程节点。当您在其实现中调用非静态方法时，它会使整个this对象被序列化。它可能会导致意外行为和通过网络发送大量数据。

一般来说，不建议通过网络发送 lambda 函数，因为它们的序列化依赖于 VM，并且无法让您控制实际发送的内容。如果您想通过网络发送谓词，则创建一个实现谓词接口的类并使用该类的实例。

如果不需要集群中的所有节点都订阅该主题，那么localListen就足够了。