本文整理汇总了Java中reactor.core.spec.Reactors类的典型用法代码示例。如果您正苦于以下问题:Java Reactors类的具体用法?Java Reactors怎么用?Java Reactors使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Reactors类属于reactor.core.spec包,在下文中一共展示了Reactors类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: initializeReactor
import reactor.core.spec.Reactors; //导入依赖的package包/类
private void initializeReactor() {
reactor = Reactors.reactor()
.env(env)
.dispatcher(Environment.RING_BUFFER)
.get();
decoderReactor = Reactors.reactor()
.env(env)
.dispatcher(Environment.RING_BUFFER)
.get();
decoderReactor.on(Selectors.$(DECODE_TOPIC), (Event<byte[]> m) -> {
try {
Envelope message = EnvelopeCodec.decode(m.getData());
message.setDecoded(false);
send(message);
} catch (IOException | MessageTypeException ex) {
LOG.error("Error decoding message.", ex);
}
});
}
开发者ID:Archarithms,项目名称:bigio,代码行数:22,代码来源:MeMember.java
示例2: main
import reactor.core.spec.Reactors; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
Environment env = new Environment();
Reactor reactor = Reactors.reactor().env(env).dispatcher(Environment.THREAD_POOL).get();
// topic: parse
reactor.on($("parse"), App::handleEvent1);
reactor.on($("parse"), App::handleEvent2);
// Notify consumers of the 'parse' topic that data is ready
// by passing a Supplier<Event<T>> in the form of a lambda
for (long l = 0; true; l++) {
String obj = "Test-" + l;
reactor.notify("parse", Event.wrap(new ObjectEvent().setObject(obj)));
Thread.sleep(1000);
}
}
开发者ID:smallnest,项目名称:DisruptorBootstrap,代码行数:19,代码来源:App.java
示例3: main
import reactor.core.spec.Reactors; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
Environment env = new Environment();
final TradeServer server = new TradeServer();
// Use a Reactor to dispatch events using the default Dispatcher
Reactor reactor = Reactors.reactor()
.env(env)
.dispatcher("ringBuffer")
.get();
String topic = "trade.execute";
// For each Trade event, execute that on the server
reactor.on($(topic), new Consumer<Event<Trade>>() {
@Override
public void accept(Event<Trade> tradeEvent) {
server.execute(tradeEvent.getData());
// Since we're async, for this test, use a latch to tell when we're done
latch.countDown();
}
});
// Start a throughput timer
startTimer();
// Publish one event per trade
for (int i = 0; i < totalTrades; i++) {
// Pull next randomly-generated Trade from server
Trade t = server.nextTrade();
// Notify the Reactor the event is ready to be handled
reactor.notify(topic, Event.wrap(t));
}
// Stop throughput timer and output metrics
endTimer();
server.stop();
}
开发者ID:bingoohuang,项目名称:javacode-demo,代码行数:41,代码来源:TradeServerExample.java
示例4: reactor
import reactor.core.spec.Reactors; //导入依赖的package包/类
@Bean
public Reactor reactor(Environment env, MailServer mailServer) {
Logger log = LoggerFactory.getLogger("mail.server");
Reactor r = Reactors.reactor(env);
// Wire an event handler to execute messages
r.on($("mail.execute"), (Event<MessageDescriptor> ev) -> {
mailServer.execute(ev.getData());
log.info("Executed message: {}", ev.getData());
});
return r;
}
开发者ID:mdarapour,项目名称:microservice-workshop,代码行数:14,代码来源:BootMailServer.java
示例5: ListenerRegistry
import reactor.core.spec.Reactors; //导入依赖的package包/类
/**
* Constructor.
*/
public ListenerRegistry() {
reactor = Reactors.reactor()
.env(environment)
.dispatcher(Environment.RING_BUFFER)
.get();
}
开发者ID:Archarithms,项目名称:bigio,代码行数:10,代码来源:ListenerRegistry.java
示例6: VisactorResourceConfig
import reactor.core.spec.Reactors; //导入依赖的package包/类
public VisactorResourceConfig() {
this.reactor = Reactors.reactor(new Environment(), Environment.RING_BUFFER);
this.store = new ListEventStore();
register(SseFeature.class);
registerInstances(new VisactorResource(reactor, store));
}
开发者ID:nobeh,项目名称:visactor,代码行数:8,代码来源:VisactorResourceConfig.java
示例7: SingletonEnvironment
import reactor.core.spec.Reactors; //导入依赖的package包/类
private SingletonEnvironment() {
env = new Environment();
defaultReactor = Reactors.reactor(env);
}
开发者ID:nickman,项目名称:HeliosStreams,代码行数:5,代码来源:SingletonEnvironment.java
示例8: rootReactor
import reactor.core.spec.Reactors; //导入依赖的package包/类
@Bean
public Reactor rootReactor(final Environment env) {
return Reactors.reactor().env(env).get();
}
开发者ID:learning-spring-boot,项目名称:contest-votesapp,代码行数:5,代码来源:VotesAppApplication.java
注:本文中的reactor.core.spec.Reactors类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论