-
1 votesanswersviews
使用Express-GraphQL和React-Apollo进行GraphQL订阅
我跟随Apollo的文档在客户端和服务器上设置了GraphQL订阅，虽然我90％在那里，但我无法弄清楚如何设置订阅 Channels 以及如何将突变连接到这些 Channels 以便每当发生突变时，服务器将新数据推送到客户端 . （对于内容，我正在制作Reddit克隆，其中人们发布主题，其他人对其进行评论 . 因此，当您看到“主题”或“主题列表”时，请将其视为帖子 . ） 到目前为止，我已成功为... -
0 votesanswersviews
使用rabbitmq队列并在 Cloud 上的Mysql中插入消息？
我开发了一个Android应用程序，它可以订阅队列，也可以发布到其他队列 . 它一次向两个不同的队列发布相同的消息，其中一个是名为“Queue”的队列，现在从appfog实例我需要订阅“Queue”并使用消息并将它们插入到mysql db中 . 我使用codeigniter为上述目的创建了一个php独立应用程序 . 由于某种原因，工作者应用程序失去了与rabbitmq的连接 . 我想知道最好的方法... -
3 votesanswersviews
如何向所有Google App Engine实例广播数据？
为简单起见，假设我的应用程序需要允许数千名用户查看聊天室的实时只读流 . 主机可以键入消息，但没有其他用户可以 - 他们只是实时查看主机键入的内容 . 想象一下，用户正在关注体育赛事的文字游戏 . 每个用户通过对GAE服务器的简单 /get-recent-messages 调用每秒轮询一次来检查新消息 . （在您提出要求之前，我相信使用Google的 Channels API会太昂贵 . ） 考... -
0 votesanswersviews
重新加载后Meteor Angular2订阅详细信息没有数据
我有使用Angular2来跟踪问题来从集合中订阅我的数据 . 当我加载列表并单击编辑时，它的工作正常 . 所有数据都在那里 . 但是，如果我改变了一些东西，服务器重新启动，因此页面正在重新加载，或者如果我只是尝试使用direkt链接进入该编辑页面，我在控制台中收到以下错误： EXCEPTION：未捕获（在承诺中）：错误：错误：0：0引起：无法读取未定义的属性'name'TypeError：无法读... -
0 votesanswersviews
Lagom：如何让客户连接到主题
我正在制作使用Lagom的实时琐事应用程序，我希望将当前连接的客户端主题发布给所有用户 . 如何在线获取用户数？ -
1 votesanswersviews
Angular 5应用程序的Pub-Sub实现
一直在WPF-Prism框架中寻找类似于 IEventAggregator 的东西 . This在我看来有点同样的问题，除了在Angular 5中寻找解决方案 . 到目前为止找不到简单的解决方案 . 不得不使用 typescript generics ， angular dependency injection 使用服务和 "rxjs/Subject" 自己创建一个 . 它主要... -
2 votesanswersviews
如何实例化多个Redis连接以进行发布订阅（node.js node_redis）
场景 使用 node_redis 构建一个简单的Redis Pubish订阅（聊天）示例：https://github.com/nelsonic/hapi-socketio-redis-chat-example（与Hapi.js和Socket.io一起使用） 我们在项目中创建了一个节点模块 redis_connection.js （参见：http://git.io/vqaos）来实例化Redis连... -
63 votesanswersviews
Node.js，Socket.io，Redis pub / sub高容量，低延迟的困难
当连接socket.io/node.js和redis pub / sub以尝试创建由可处理多个传输的服务器事件驱动的实时Web广播系统时，似乎有三种方法： 'createClient' redis连接并订阅 Channels . 在socket.io客户端连接上，将客户端加入socket.io Session 室 . 在redis.on（"message"，...）事件中... -
1 votesanswersviews
xmpp pubsub服务（XEP-0060）在收到订阅请求时是否可以创建节点？
我们使用XMPP XEP-0060发布/订阅功能来构建通知系统 . 根据XEP-0060，可以在发布时自动创建节点 . 我的问题是它可以在 subscribing 时创建吗？ 如果没有，是否有任何替代解决方案来实现这一点？ （订阅后创建节点） 谢谢 -
1 votesanswersviews
WCF PUB - SUB模式配置文件用法
Overview of Project: 我有一个WCF服务和2个桌面应用程序（一个发布者，第二个订阅者） . WCF服务托管在Windows Server 2008 R2 Std Edition上，发布服务器位于同一台计算机上 . 订阅者在客户端计算机上 . WCF服务使用net.tcp绑定，因为它位于公共IP上，而其他绑定具有NAT问题 . 订阅服务器在订阅时创建回调通道，并且WCF服务调用... -
0 votesanswersviews
Android Nearby Messages API发布'Expected BEGIN_OBJECT but was STRING'
我正在尝试使用附近的示例，请点击此链接：https://developers.google.com/nearby/messages/android/pub-sub 我想订阅并发布一个小文本 . 所以我补充说： private Message mActiveMessage; private void publish(String message) { Log.i(TAG, "Pu... -
0 votesanswersviews
Kafka关于消费者群体的问题
我是 Kafka 的新手 . 我瞥了一眼Kafka文档 . 似乎通过将分区与使用者实例绑定来实现分派给订阅使用者组的消息 . 当我们使用Apache Kafka时，我们应该记住的一件重要事情是，同一个消费者群体中的消费者数量应该小于或等于消费主题中的分区数量 . 否则，将不会从该主题收到超出消费者的任何消息 . 在非prod环境中，我没有配置主题分区 . 在这种情况下，Kafka中只有一个分区... -
0 votesanswersviews
NoSuchMethodError：com.google.api.gax.rpc.ApiClientHeaderProvider $ Builder.setGeneratorHeader
我已经开始使用谷歌 Cloud pub / sub，当我试图发布消息到一个主题低于错误 . 线程“main”中的异常java.lang.NoSuchMethodError：com.google.api.gax.rpc.ApiClientHeaderProvider $ Builder.setGeneratorHeader（Ljava / lang / String; Ljava / lang / ... -
23 votesanswersviews
如何使用Spring-websocket基于用户权限拒绝主题订阅
我正在实现一个版本的股票应用程序，其中服务器能够根据用户权限拒绝特定主题的主题订阅 . spring-websocket有没有办法做到这一点？ 例如： 在库存示例项目中我们有3个仪器的价格主题：Apple，Microsoft，Google并且有两个用户：User1，User2 User1应该可以访问Apple，Microsoft User2应该只能访问Google 如果User1订阅Google... -
0 votesanswersviews
CometD客户端Java APIn如何？
对于我的项目，我必须使用 pubsub 和 cometD 订阅者 . 我使用Oracle Weblogic 应用程序服务器进行两次应用程序 . 其中一个向pubsubs Channels 发布一些消息，另一个订阅 Channels 以显示消息 . 我的pubsub服务器也在weblogic应用服务器上，并配置了一些xml文件（weblogic.xml和weblogic-pubsub.xml） .... -
1 votesanswersviews
哪个解决方案更好地处理发布者/订阅者方案？
该场景是发布者/订阅者，我正在寻找一种解决方案，该解决方案可以实现在MULTIPLE消费者实时发送由ONE 生产环境 者生成的一条消息的可行性 . 这个场景可以通过一个解决方案来处理轻量级，效果更好！ 在AMQP服务器的情况下，我只检查了Rabbitmq并使用rabbitmq服务器进行发布/订阅模式，每个消费者都应该声明一个匿名的私有队列并将其绑定到扇出交换，因此如果有一千个用户在实际中消费一条消... -
0 votesanswersviews
MQTT到 Kafka . 如何避免重复
我的要求是负载 balancer 在不同VM上运行的2个MQTT节点，然后让消费者在两个节点上使用这些MQTT代理 . 消费者的工作是订阅一个主题，在收到数据后，将其发布到Kafka . 问题我看到，如果由于两个MQTT消费者都订阅了相同的主题，他们将收到相同的消息，并且两者都会将其插入到Kafka中，从而创建重复项 . 反正是为了避免将副本写入 Kafka ？ 我曾尝试过Mosquitto和... -
1 votesanswersviews
通过WebSockets从Web应用程序访问pub / sub系统
我需要一个Web应用程序实例来通过WebSocket接收通知 . 这些通知来自后端系统中的事件;这些事件需要以多种方式处理，而不仅仅是推送给客户 . 因此，发布/订阅系统是理想的：如果事件与其操作相关（例如，通过主题），则发布事件并且n个消费者处理它们 . 鉴于我对WebSocket缺乏了解，我很难理解我需要实施的整体架构 . 在pub / sub世界中，消费者订阅与他们感兴趣的“主题”相关的消息... -
0 votesanswersviews
Akka流：将新的发布者/订阅者附加到Flow
我正在构建一个Akka应用程序，并希望将某些actor的FSM状态转换暴露给外部消费者 . （最终目标是能够将状态转换消息推送到websocket，以便可以实时查看它们 . ） 根据文档Combining dynamic stages to build a simple Publish-Subscribe service，看起来我需要公开代表pub-sub通道的Flow，以便消费者和 生产环境 ... -
0 votesanswersviews
Lagom与Kafka发布消息
只有一种出版方式被描述为here . 还有另外一种方法吗？我需要使用动态主题ID和没有persistentEntityRegistry的自定义事件制作出版物的示例？如何使用eventId发布事件？ @Override default Descriptor descriptor() { return named("helloservice").withCalls( ... -
1 votesanswersviews
线程“main”中的异常java.lang.UnsatisfiedLinkError：Eclipse中java.library.path中没有jzmq
导入org.zeromq.ZMQ; 对于上面的import语句，我在jzmq主文件夹中使用“org文件夹”，该文件夹由ZMQ.java文件组成 . 所以，编译没有问题 . 当我开始运行程序时，它显示以下异常 线程“main”中的异常java.lang.UnsatisfiedLinkError：java.lang.ClassLoader.loadLibrary（未知来源）java.lan... -
0 votesanswersviews
使用Elasticsearch和SignalR过滤和推送CQRS模式
细节： 命令API处理为CQRS模式并将 Read Model 持久保存到Elasticsearch . Observer-side通过Web API注册过滤条件 . 如果满足过滤条件，则通过SignalR API将 Read Model 推送到观察者侧 . 关注： 过滤条件必须使用Elasticsearch Query DSL，而不是应用程序端逻辑，因为它们是灵活且复杂的 .... -
3 votesanswersviews
无法在rospy中发布订阅的主题
我正在使用ROS和python，我已经编写了这段代码 . 这段代码应该订阅一个名为“map”的ROS主题（来自hector_slam，使用LIDAR）并将其保存到一个名为“mapdata”的变量中，稍后将使用该变量 . 我只想通过将其作为另一个名为'mapprob'的ROS主题发布来确保正确导入它 . 代码编译并运行正常，但“mapprob”中没有任何内容发布 . 我确保“map”发布'Occup... -
10 votesanswersviews
Websockets Notification- / Chat- System
我已经阅读了很多关于websockets的内容，并且已经在我的系统中实现了它们 . 这个问题是关于如何正确使用它们 . 我想以正确的方式实现通知和聊天系统 . 对于通知，我有 Channels “通知/ Channels ”，对于聊天，我有 Channels “聊天/ Channels ” . 这两个渠道不是太“全球化”吗？假设当该网站拥有1.000.000个用户时，这意味着所有这些用户都将处于这... -
12 votesanswersviews
在zeromq pub sub上丢失了消息
我正在尝试使用zeromq框架实现pub子设计模式 . 我们的想法是推出订阅者，然后推出发布者 . 订阅者将收听100条消息，发布者将发布100条消息 . 到目前为止一切都那么好......然而实际发生的事情是，即使发布者发布时订户已经启动并运行，订阅者也不会收到所有消息（订阅者将收到100条消息，如果出版商将发送至少500条消息） . 似乎发布者发送的第一条消息不会发送给订阅者 . 有任何想法吗... -
3 votesanswersviews
如何使用Java通过Push in Cloud Pub / Sub接收消息
我正在尝试使用Java实现Google Cloud Pub / Sub来接收消息（通过Push）但我找不到Java的文档 . 我能够通过pull接收消息，也可以在本地设置和测试 endpoints 的任何线索都非常有帮助 . 我已经验证并添加了域名作为 endpoints ，想知道下一步该做什么以开始在该 endpoints 接收消息 . -
0 votesanswersviews
适用于移动应用的Amazon SNS主题订阅确认
我想了解亚马逊SNS如何确认移动应用程序的 endpoints 订阅 . 对于SMS，HTTP或电子邮件enpoints，我们可以假设发送确认短信，电话和电子邮件 . 但对于应用程序，SNS似乎通过第三方服务（如GCM，APNS等）管理所有通知 . 假设我已准备好GCM客户端和服务器 . 我的客户想要订阅一个主题 . 如何将确认消息发送到设备？ -
8 votesanswersviews
实时Web库 - 用socket.io替换hookbox或者什么？
我有几个使用hookbox构建的项目来管理Web客户端和服务器之间的实时消息传递 . Hookbox很棒 - 它完全抽象了传输层，通过优雅的安全系统在不同的通道上展示了一个简单的发布/订阅接口 . 不幸的是，由于最初的维护者不愿意放弃所有权，因此钩子项目很快陷入混乱 . （Grrr！）因此很难将它视为一个可行的平台 . 什么是提供与Web应用程序实时通信的良好平台？要求： 使用HTML5 ... -
0 votesanswersviews
使用NodeMCU板通过MQTT代理订阅多个发布者
我有几个关于这个主题的问题，所以我将在这里完全发布，否则我必须单独发布有关单独问题的帖子 . 场景是我有NodeMCU板，我将用它通过MQTT代理（MQTT盒）从多个发布者接收多条消息 . 以下是我需要澄清的查询，我还没有实现，我只是形成逻辑 . 假设我将通过MQTT代理连续从4 NodeMCU板接收消息，然后我将其发送到服务器进行存储，问题是 1个发布者的消息是否会覆盖另一个发布者的消息，然... -
0 votesanswersviews
使用PubSubClient.h回调函数的NodeMCU esp8266被忽略
EDIT ：发布和订阅的主题即使看起来不同也是正确的 . 随着我的发布，我写在字段4.此外，我在子/ pub模式下运行MQTT.fx与相同的主题，它的工作完美 . 我想在我的NodeMCU和esp8266上使用mqtt . 我将simple MQTT example改编为我的最小项目 . 在我的代码中（附后）我正在尝试发布和订阅ThingSpeak Channels . 发布函数没有任何问题，它...