- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我想我会研究 Pivotal 新发布的 reactor 框架,以了解我正在编写的一个简单程序,该程序需要一些多线程才能及时完成。
我编写了以下示例项目来了解框架并使用它来了解它的使用方式:
主.java:
package reactortest;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
public class Main {
public static void main(String[] args) throws InterruptedException {
try(AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(MainConfiguration.class)) {
MyProducer producer = context.getBean(MyProducer.class);
producer.run();
}
}
}
MyProducer.java:
package reactortest;
import java.util.concurrent.CountDownLatch;
import reactor.core.Reactor;
import reactor.event.Event;
public class MyProducer {
private final Reactor reactor;
private final Integer messagesToPrint;
private final CountDownLatch countDownLatch;
public MyProducer(final Reactor reactor, final Integer messagesToPrint, CountDownLatch countDownLatch) {
this.reactor = reactor;
this.messagesToPrint = messagesToPrint;
this.countDownLatch = countDownLatch;
}
public void run() throws InterruptedException {
for(int i = 0; i < messagesToPrint; ++i) {
reactor.notify(Event.wrap("String event: " + i));
}
countDownLatch.await();
System.out.println("Finished. Remaining count is: " + countDownLatch.getCount());
}
}
MyConsumer.java:
package reactortest;
import java.util.concurrent.CountDownLatch;
import reactor.event.Event;
import reactor.function.Consumer;
public class MyConsumer implements Consumer<Event<String>> {
private final CountDownLatch countDownLatch;
public MyConsumer(CountDownLatch countDownLatch) {
this.countDownLatch = countDownLatch;
}
@Override
public void accept(Event<String> message) {
System.out.println(message);
countDownLatch.countDown();
}
}
最后,MainConfiguration.java:
package reactortest;
import java.util.concurrent.CountDownLatch;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.Environment;
import reactor.core.Reactor;
import reactor.core.spec.Reactors;
import reactor.spring.context.config.EnableReactor;
@Configuration
@EnableReactor
public class MainConfiguration {
private final Integer MESSAGESTOPRINT = 10;
@Autowired private Environment environment;
@Bean
public CountDownLatch countDownLatch() {
CountDownLatch countDownLatch = new CountDownLatch(MESSAGESTOPRINT);
return countDownLatch;
}
@Bean
public Reactor reactor() {
Reactor reactor = Reactors.reactor().env(environment).dispatcher(Environment.THREAD_POOL).randomEventRouting().get();
reactor.on(consumer());
return reactor;
}
@Bean
public MyProducer producer() {
MyProducer producer = new MyProducer(reactor(), MESSAGESTOPRINT, countDownLatch());
return producer;
}
@Bean
public MyConsumer consumer() {
MyConsumer consumer = new MyConsumer(countDownLatch());
return consumer;
}
}
我的问题是程序永远不会完成。消费者每次运行也会打印出不同的信息。它从连续三个运行中打印出:
1st run:
Event{id=null, headers=null, replyTo=null, data=String event: 0}
Event{id=null, headers=null, replyTo=null, data=String event: 1}
Event{id=null, headers=null, replyTo=null, data=String event: 7}
Event{id=null, headers=null, replyTo=null, data=String event: 8}
2nd run:
Event{id=null, headers=null, replyTo=null, data=String event: 0}
Event{id=null, headers=null, replyTo=null, data=String event: 1}
Event{id=null, headers=null, replyTo=null, data=String event: 5}
Event{id=null, headers=null, replyTo=null, data=String event: 6}
Event{id=null, headers=null, replyTo=null, data=String event: 9}
3rd run:
Event{id=null, headers=null, replyTo=null, data=String event: 2}
Event{id=null, headers=null, replyTo=null, data=String event: 4}
Event{id=null, headers=null, replyTo=null, data=String event: 6}
似乎我一定错过了一些非常明显的东西,因为除了这是 javaconfig 而不是配置的注释,并且没有与外界进行任何交互之外,我看不出这与示例有何不同 here .
最佳答案
在问这个问题时,我正在改进代码,它最终起作用了(一些 great rubber ducking 在那里)。我想与其删除我的问题,不如将其发布,以防其他人遇到同样的问题。
上述代码的问题是在设置 react 堆时调用 randomEventRouting(),当设置此标志时,它会随机选择要路由到的消费者。因为我没有设置特定的选择器/键来定义要分派(dispatch)给的消费者,并且由于在没有提供键时所有消费者都匹配,所以我假设在幕后设置了一个默认消费者,它正在传递我的一些事件.
更改 reactor.on() 以接受选择器:
reactor.on(Selectors.$(selector()), consumer());
选择器的位置很简单:
@Bean
public String selector() {
String selector = "My very special event";
return selector;
}
并将此 key 注入(inject)生产者,并在调用 reactor.notify() 时使用它:
reactor.notify(selector, Event.wrap("String event: " + i));
按预期工作。
我想这是一个非常极端的情况,因为大多数用户将(并且应该)定义键,但你永远不知道。 :)
关于java - 我正在使用 spring-reactor 丢失消息,我的设置有什么问题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20400548/
我在 Ubuntu 10.04 LTS 上运行 Eclipse Galileo。今天 Ubuntu 在我身上崩溃了,重新启动后,我发现 Eclipse 已经完全失去了 Java Perspective
我使用配置了 sonata_user 的 SonataAdminBundle在 config.yml : sonata_user: impersonating: route:
我有 ubuntu 14.04 但它不见了 docker exec sudo docker exec -it ubuntu_bash bash 我希望在现有正在运行的 docker 容器中运行交互式
我正在使用 Ubuntu 8.04/32 位(作为虚拟机)。在一个不是 min 的项目上执行一些 make 时,我得到了错误: g++:/usr/lib/libstdc++.a: 没有这样的文件或目录
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 我们不允许在 Stack Overflow 上提出有关通用计算硬件和软件的问题。您可以编辑问题,使其成为
我正在尝试获取有关我在 UIImagePicker 中选择的视频的一些数据。 因此,当它进入 UIImagePicker 委托(delegate)方法(如下)时,我知道我需要使用信息字典中的 UIIm
我的网站最近被可能的黑客行为删除了。我上传了备份的文件夹和数据库,但现在我的 View 没有显示。其他一切都有效。我想不出有什么变化,只是上传了几天前的备份。 这些字段在 admin/build/vi
我执行以下操作来设置我的 session ,这是有效的,因为 echo 出现了。但是当我转到下一页或另一页时, session 不存在吗?我做错了什么? $session_start(); if ($
我试图在 BigQuery 中使用这段代码,显然是从 GA 中获取数据,但 _TABLE_SUFFIX 似乎有问题。错误显示“错误:无法识别的名称:_TABLE_SUFFIX at [12:3]”您能
输入:8(2 5 6 9 10 2 7 4)预期输出:(2 7 9 9 12 5 7 6)实际输出:(2 7 9 9) 这是我的大学作业,也是我第一次在这里提问。我不知道为什么,但 10 没有扫描,有
$('div'); // 我在上面的代码中遇到错误。在检查 .js 代码时,我找不到名为 $ 的函数,但根据文档,应该有一个。 最佳答案 试试 http://ajax.googleapis.co
以下简单代码的输出对我来说有点奇怪。它错过了在控制台上打印的 0 到 100 之间的一些数字。 谁能解释一下为什么省略打印?我对并发编程完全陌生。 import java.util.concurren
我正在学习 xamarin 以构建移动应用程序,但我对 Xamarin 和移动应用程序一无所知。我打开了一个空白的移动应用程序,其中有“Hello world”示例并编辑了一些文本,但我的应用程序图标
我正在将一些值存储到 sqlite 数据库中。因此,数据是作为字符串从文本字段收集的,然后转换为 double 并持久化。 这是我试过的 NSDecimalNumber 答案; value.answe
我有一个奇怪的案例。突然,其中一个表中的一些记录(这么多记录)丢失了。首先,我认为这是由我的 PHP 脚本中的错误引起的。但是,我检查了一下,我的脚本中没有DELETE操作,只有UPDATE。有谁知道
我正在复制 NSString来自 NSDictionary进入本地NSString使用 [[NSString alloc] initWithString:] ,对其进行处理(删除一些字符),然后将其发
当保存在根文件夹中时,我的非常基本的 html 页面保持样式。为一个组创建了一个新文件夹,但是当我将页面移动到该文件夹时,它们似乎失去了与 css 文件的连接。 认为问题可能出在链接上,因为它现在
我需要使用 OpenCV 训练一些图像。但问题是,我找不到 opencv_createsamples 程序。我以正常方式安装了 OpenCV,因为我使用的是 Windows 7。这个 opencv_c
我有一个绑定(bind)到 JTable 的 ArrayList。之后 bindingGroup.unbind(); bindingGroup.bind(); (完成刷新数据)我丢失了表格单元格渲
所以基本上我们只是丢失了一个 keystore 和备份 keystore 。但是我们可能知道原始 keystore 的密码。 我的问题是,如果我们知道原始 keystore 的密码,我们可以重新生成
我是一名优秀的程序员,十分优秀!