不同主机上的Esper发布者和订阅者
是否有任何示例代码可以让一个主机发布事件，而另一个主机通过Esper框架接收事件（侦听器或订阅者）。我注意到Esper提供了不同的适配器（套接字、JMS和HTTP），但找不到相应的示例代码。谢谢
共有1个答案
埃斯佩里奥[1]将是你正在寻找的[1]http://esper.codehaus.org/esperio-4.9.0/doc/reference/en-US/html_single/index.html
-
目前，我已经开始使用ActiveMQ处理JMS主题。我已经通过JAVA代码（如下所述）创建了发布者和持久订阅者，并且在订阅者端也收到了消息。 Publisher.Java 订阅者.java 我对以下主题有一些疑问， 如何检查有多少订阅者使用 Java JMS 在主题中主动查找消息？ 如何从主题中获取活动和持久订阅者列表？ 我们是否可以删除主题中发布的消息？ 在这些情况下帮助我。 提前致谢。
-
这只是为了澄清发布/订阅线程。 我的疑问是在正常的发布者/订阅者模式中，订阅者和发布者是在同一个线程上运行还是在不同的线程中运行？ 还是取决于实现？ 到目前为止，我所想的是不同的订阅会有自己的线程，而publisher在其上运行的是自己的线程？
-
发布和订阅 Meteor 服务端可以通过Meteor.publish发布文档集，同时客户端可以通过Meteor.subscribe订阅这些发布。 任何客户端订阅的文档都可以通过find方法进行查询使用。 默认情况下，每个新创建的 Meteor 应用包含有 autopublish 包，它会自动为每个客户端发布所有可用的文档。 为了可以更细化的控制不同客户端所接收的数据文档,首先应该在终端移除 aut
-
我想用Java实现各种各样的发布者/订阅者模式，但目前已经没有主意了。 有1个发布者和N个订阅者，发布者发布对象，然后每个订阅者需要按照正确的顺序对每个对象进行一次且仅处理一次。发布者和每个订阅者在自己的线程中运行。 在我最初的实现中，每个订阅者都有自己的阻塞队列，发布者将对象放入每个订阅者的队列中。这可以正常工作，但如果任何订阅者的队列已满，发布者将被阻塞。这会导致性能下降，因为每个订阅者处理对
-
我正在创建一个API来发布和使用来自RabbitMQ的消息。在我当前的设计中，发布者将发出一个POST请求。我的API会将POST请求路由到Exchange。这样，发布者在发布时就不必知道服务器地址、exchange名称等。 现在消费者部分是我不确定如何继续的地方。 开始时不会排队。当一个新的消费者想要订阅一个主题时，那么我将创建一个队列并将其绑定到交换。我需要一些问题的答案- 一旦我为使用者创建
-
简介 Redis 的列表类型键可以用来实现队列，并且支持阻塞式读取，所以 Redis 能够非常容易的实现一个高性能的优先队列。同时在更高层面上，Redis 还支持“发布/订阅”的消息模式，可以基于此构建一个聊天系统。 发布示例 发布（Publish）即将消息发布到频道中。示例代码： // 发送消息 Redis::publish('chan-1', 'Hello, World!'); // 发送消息