apache点燃数据流

Question

我有一个关于Ignite流媒体部分的问题。

我所理解的是，这是一种将数据导入缓存的方式，但我也看到，我们可以配置流接收器来应用一些其他的自定义逻辑。

所以我尝试创建一个包含接收器的类和一个将数据注入流的类（因此在服务器模式下有2个main和2个Ignite实例），但我“只是”将数据放入流的缓存中（接收器中没有任何自定义逻辑处理）。所以，我在问我是不是错过了什么，或者是我不太理解什么是流到点燃。

如果我把发件人的部分放进接收器，我就有指纹了。

有人知道我做（或理解）错了什么吗？

接收器类：

public class Receiver {
    public static void main(String[] args){
        IgniteConfiguration igniteConfig = new IgniteConfiguration();
        CacheConfiguration<String, String> cacheConfig = new CacheConfiguration<>("CacheStream");   


        igniteConfig.setCacheConfiguration(cacheConfig);


        Ignite ignite = Ignition.getOrStart(igniteConfig);

        IgniteDataStreamer<String, String> streamer = ignite.dataStreamer("CacheStream");

        streamer.receiver(StreamVisitor.from((cacheLambda, e) -> {
            System.out.println("Value : " + e.getValue());
        }));
    }
}

发件人类：

public class Sender {
    public static void main(String[] args){
        IgniteConfiguration igniteConfig = new IgniteConfiguration();
        CacheConfiguration<String, String> cacheConfig = new CacheConfiguration<>("CacheStream");

        igniteConfig.setCacheConfiguration(cacheConfig);

        Ignite ignite = Ignition.getOrStart(igniteConfig);

        IgniteDataStreamer<String, String> streamer = ignite.dataStreamer("CacheStream");

        for(int i = 0 ; i < 10 ; i++){
            streamer.addData("key-"+i, "value-"+i);
        }
        streamer.flush();
    }
}

Answer 1

ignite.datastreamer（“CacheStream”）不返回您之前创建的相同数据流，它每次都创建新的datastreamer。

因此，在您的例子中，您配置了两个不同的DataStreamer，并且使用没有配置接收器的流光上传数据。