1. IT宝库
  2. 编程技术问答
  3. publish-subscribe
以下是关于 publish-subscribe 的编程技术问答
php读取XML邮政请求
所以，我执行了两个步骤 a)在一个PHP文件之一中创建一些随机的XML文件. b)在第二个文件中解析相同的XML文件. 关键点是 a)中的PHP文件将向PHP文件发出邮政请求b)仅用XML作为其请求. 文件b)必须使用单纯词读取XML文件. 我正在尝试为此做些 http://http:////////blog.superfeedr.com/api/pubsubhubbub/getting-with-pubsubhubbub/. i我的服务器将从SuperFeeder接收XML形式的通知.通知将是请求中的XML文件. 我正在做步骤a)只是为了确认我的部分b)是正确的. 如何在PHP中执行此操作. 我尝试了所有$ _request，$ GLOBALS变量.但是，不确定是怎么回事！ 解决方案 我不确定我知道您要做什么，而是尝试尝试阅读原始帖子数据.这是一篇博客文章，讨论了一点. http://www.codediesel.com/phpp
0 2023-05-29
编程技术问答社区
一个只为使用通道而定制的Phoenix应用程序如何能在多台机器上扩展？使用HAProxy？如何向所有节点广播消息？
i纯粹将节点应用程序用于socket.io通道带有redis pubsub，目前我将其分布在3台机器上，并在其中一台计算机上以Nginx负载平衡来支持. 我想用Phoenix应用程序替换此节点应用程序，而且我仍然是Erlang/Elixir World的新手，因此我仍然没有弄清楚单个Phoenix应用程序如何在一台以上的计算机上涵盖.谷歌搜索所有可能的缩放和负载平衡项一无所获. 1.0 1.0版本注释关于渠道的提及: 即使在一组机器上，您的消息也会在节点上广播 1)So 我基本上将应用程序部署到n服务器，在每个服务器中启动牛仔服务器， 与我使用节点的方式相似，它们将它们绑住了Nginx/haproxy ? 2)如果是这种情况，频道消息如何在发行说明中提到的所有节点播放? 编辑3:服用 theston 答案可以澄清没有凤凰应用程序之类的东西Erlang应用程序，我更新了搜索词，并找到了有关缩放和负载平衡的一些有趣结果. 一本免费的广泛书籍: erl
2 2023-05-25
编程技术问答社区
如何从java程序中为ibm mq amqp主题创建持久订阅？
我们通过提供clientId和订户名称. 我们启动该程序，以便订阅主题并停止程序.然后将MSG发送到主题，然后再次启动接收器程序，但我们无法接收发送的味精，并放松在持久订阅中不应发生的消息. 使用MQSC命令DISPLAY TOPIC，DISPLAY TPSTATUS，DISPLAY TPSTATUS SUB，DISPLAY SUB SUBID连接订阅者时，我们可以看到AMQP主题及其持久订阅，但在停止订户程序时却没有.我们已经定义了属性DEFPSIST(YES)和客户端(主题制作人)正在发送持久消息. 消息在哪里走了，因为我们看不到订户持久队列中的消息?这取决于到期属性吗? DISPLAY SUB SUBID输出我们的订户连接时. AMQ8096: WebSphere MQ subscription inquired. SUBID("hex sub id") SUB(:private:CLINET01:TOPIC01) TOPI
2 2023-05-22
编程技术问答社区
使用smack读取pubsub中传入的Message数据包
我正在尝试使用openfire服务器和asmack库来实现PubSub. 我已经配置了我的节点，以至于subscribers必须批准publishers 现在，我正在尝试使用以下代码读取Message数据包，但我没有得到任何数据包.我想阅读Message数据包，因为我想知道订阅者何时将请求发送给发布者获取订阅. PacketTypeFilter filter = new PacketTypeFilter(org.jivesoftware.smack.packet.Message.class); PacketListener myListener = new PacketListener(){ @Override public void processPacket(Packet packet) { // TODO Auto-generated method stub Log.d("P
0 2023-05-10
编程技术问答社区
OpenFire-使用PubSub的永久群聊
首先是这个问题: Asmack/openfire How do I keep a用户在GroupChat Room中永久 我读到我不能使用MUC将用户持续在小组中，他们会自动离开小组并可以在他们再次上网后重新加入，该概念就像IRC一样，就像在这里所问的一样 - >> http://community.ignitereality.orgeterealtime.org/thread/thread/480202020 . 然后，我从我读过的有关使用pubsub的stackoverflow问题中进行了一些有关pubsub的研究，而我得到的是pubsub可以持续使用用户在组中，甚至用户离线，但消息流量为更像是从发布者到订户的一个方向性(只读). 因此，如果我想创建一个组聊天应用程序，我可以使用pubsub并将所有成员设置为出版商和订户吗?还是有其他解决方案?还是我对PubSub和MUC的理解是不正确的? 我的目标是在WhatsApp或Blackberry Messenger组中创建一
12 2023-05-10
编程技术问答社区
Openfire Android的PubSub订阅请求获得批准
我是OpenFire和Smack的新手，因此我对PubSub功能有疑问.实际上，我创建了一个用 setAccessModel 的节点，如授权，如下所示. PubSubManager mgr = new PubSubManager(xmpp.getConnection()); try { LeafNode leaf = mgr.createNode("testNode"); ConfigureForm form = new ConfigureForm(DataForm.Type.submit); form.setAccessModel(AccessModel.authorize); form.setDeliverPayloads(true); form.setNotifyRetract(true); form.setPersistentItems(true); form.setPublishModel(PublishModel.
6 2023-05-10
编程技术问答社区
在实现中使用数据库时，观察者模式和pub-sub是否相同？
我试图了解观察者模式并陷入特定点.在我的理解中，一旦观察者订阅以在任何事件更改上通知它们，则将订阅存储在某个地方，然后当事件更改时，通知订户. 在实际情况下，由于持久原因，我应该将值存储在数据库或文件中，并在事件发生后通过从DB获取并循环浏览列表. . 这是正确的理解吗?我没有看到任何涉及数据库的示例，但是，每个示例都使用列表. 又一次出版商/订户模式也相似，除了更改，没有确切了解出版商和订户是谁，而MQ或某种类型的中级技术则用于在两个之间建立通信. . 我的问题是:当我们在观察者模式中使用DB时，它不会成为发布者/订阅者(除了在这里了解观察者和发布者).这是正确的理解吗? 解决方案 在大多数观察者模式的示例中，您会看到使用列表，但是该列表的初始化如何取决于您的应用程序.例如，与您的情况一样，具有大量订户的应用程序必须出于持久原因存储这些订户.我们不能指望如此大量的订户一直在内存中.因此，观察者列表仅从DB中初始化，尽管并非所有条目都可以.这完全是一个
8 2023-05-07
编程技术问答社区
如何在非亲子反应组件之间共享数据?
在儿童关系中共享数据之间共享数据的过程已充分记录并在React文档中直接处理.不太明显的是一个人如何共享状态和不共享儿童关系的组件之间的任意数据的公认方法. Flux是作为解决方案的，过去我已经滚动了自己的酒吧/子系统，但是在该领域的ReactJS开发人员之间似乎仍然存在很大的鸿沟. RXJS已作为解决方案提供，并且在观察者模式上提供了许多变体，但是我想知道是否有一种更具规范的方式来管理此问题，尤其是在组件不太紧密绑定的较大应用程序中. 解决方案 我的解决方案通常是通过回调作为将接受用户输入的组件的道具.回调在父母中执行状态变化，该变更传播.例如: UI = React.createClass({ getInitialState() { return { text: "" }; } hello(text) { this.setState({ text: text }); } render() {
20 2023-05-07
编程技术问答社区
观察者、Pub/Sub和数据绑定之间的区别
观察者模式 > 我在堆栈溢出上搜索了一些搜索，但找不到任何好的答案. 我认为数据绑定是一个通用术语，并且有不同的方法可以实现它，例如观察者模式或pub/sub模式.有了观察者模式，可观察到的观察者更新了.使用Pub/sub，0-许多出版商可以发布某些类的消息，而0-订户可以订阅某些类的消息. 是否还有其他实现"数据绑定"的模式? 解决方案 这是我对三个的看法: 数据绑定 本质上，从核心上讲，这只是"属性x上的属性x的值在语义上与属性A上的值绑定. 观察者或可观察/观察者 一种设计模式，可以通过将对象通知其他事件的能力 - 通常使用实际事件进行，这些事件像对象中具有特定函数/方法的形状一样.可观察到的是提供通知的人，观察者收到这些通知.在.NET中，可观察的可暴露事件，观察者用"事件处理程序"形挂钩订阅该事件.没有对发生通知的特定机制的假设，也没有对一个可观察的观察者的数量进行通知. . Pub/sub 可观察/观察者模式的另一个名
编程技术问答社区
使用Scala'的ObservableMap
我正在尝试使用scala.collection.mutable.observablemap. 我抓住了下面的摘要 scala-user 并将其复制到repl. 电子邮件提到的票证2704已被标记为固定，但该片段不起作用. 那么语法是否更改或订阅被错误地称为? 这是在2.9.0. -final 上 scala> import scala.collection.mutable._ import scala.collection.mutable._ scala> import scala.collection.script._ import scala.collection.script._ scala> class MyMap extends HashMap[Int,Int] with ObservableMap[Int,Int,MyMap] :13: error: wrong number of type arguments for sc
0 2023-05-07
编程技术问答社区
NServiceBus中的订阅者发送自动订阅消息时的条件
我发现，即使我的NSB进程未处理DTOXXX的消息，它仍在向发行者队列发送auto-subscribe消息. 这不是所需的行为.我希望该过程发布并订阅Dtoyyy的消息，但是严格发送使用DTOXXX的任何通信. 如果还不够清楚，我有2个包含我的DTO的组件.我想建立一个酒吧/子总线，但仅用于yyy.dll中的组件.至于另一个组件中的DTO，我希望仅通过发送(不是pub sub)进行通信. 我遇到的问题是NSB即使是: XXX组件中的DTO没有处理程序.仅引用它，以便YYY NSB可以将消息发送到XXX NSB. 严格发送两个模块之间的通信.考虑到实际的用例和BIZ要求，这是为了促进低耦合. 如何正确设置模块?那就是我需要以某种方式告诉NSB，自动订阅消息，但仅用于给定的名称空间/汇编中的消息. 解决方案 您可以通过在配置接口中实现自己的deleingeventsas来定义自己的规则，以将其视为命令/事件(或普通消息). NSB仅适用于事件.这可能会
6 2023-04-28
编程技术问答社区
多个NServiceBus发布者能否共享同一个DBSubscriptionStorage？
查看出版物cubscribe 我曾希望我可以更改表的名称，以便为多个发布者使用相同的数据库，但是此线程似乎表明您不能. 重点是 - 我完全理解并同意每个事件类型具有单个发布者端点的概念 - 但这不可避免地会导致让多个发布者在相同的应用程序范围内运行.也许在不同的组件或过程中运行，但这是一个有争议的点；无论如何，这意味着所有或大多数发布者都将共享相同的交易数据库.因此，为每个单独的发布者而言，必须实际创建单独的SQL 数据库的可能性似乎有些荒谬.我们最终会有数百个单桌订阅数据库. dbsubscriptionstorage是否也足够的信息来识别发布者，以便多个发布者都可以指向同一数据库?或者如果没有，我可以使用一些配置更改或黑客来完成相同的最终结果? 或我实际上需要一个为每个发布者的单独数据库 - 通过扩展，每个已发布的消息类型? 解决方案 您绝对可以在同一数据库中使用同一表来存储多个发布者的订阅.由于每个发布者对其特定消息类型负责，因此不会有逻辑重叠.
4 2023-04-28
编程技术问答社区
nservicebus如何从1个逻辑服务的两个物理位置发布消息
是否可以将部署到2个物理位置的1个逻辑服务中发布消息? 配置文件的外观如何? 您不能在订户中添加消息2次.但是，如果您想订阅2个队列. 解决方案 是的，这很可能.我们现在正在这样做.诀窍是拥有共享或复制的订阅存储.这是其工作方式: 订阅请求(如订户的应用程序配置文件中定义)发送到发布者的终点. 发布者将请求添加到其订阅商店，该订阅商店通常是一个关系数据库. 如果共享数据库/复制数据库，则所有发布者端点都会知道新订户. 所有发布者端点都将能够发布，订户将能够接收所需的消息. 其他解决方案 这是DB亚重量存储旨在求解的内容.只需配置两个物理发布者以共享相同的sub.db，就可以了.然后让您的订阅者订阅其中之一. 其他解决方案 我相信这是不可能的.无论如何，您都会在中间进行某种调度员. 发布者使用ibus.send()直接向调度程序发送消息，又使用ibus.publish(). 发布.
20 2023-04-28
编程技术问答社区
共同充当工人和订户的终点
是否可以配置一个端点，以作为从分销商中检索作业并订阅某种消息的工人? 我有以下方案(适用于销售术语) *)中央部时不时发布新价格列表.所有工人都必须通知.这意味着，工人应订阅此事件. *)当新订单到达中央时，它将其发送给分销商，将其发送给下一个要处理的空闲工人.这意味着，必须将工人配置为从分销商接收消息. 我使用以下配置:
18 2023-04-28
编程技术问答社区
SQL Server 2008表更改(插入/update/delete)在代理上推送通知
我有一个相当复杂且大的数据库，其中约3000个以上的对象(表/触发器/SPS组合).我继承了这个数据库，重组大概还有3 - 4年的路程. 同时，我需要为这些表上的任何插入/更新/删除实现Pub子功能.给定的表和现有查询可能的查询通知(和SQL依赖关系)将无效.我正在寻找的方法是在服务经纪上推动更改(如记录PK和表名称)，以便我可以使用外部激活剂来检索更改，然后从此开始使用我的自定义酒吧sub向前. 我几乎所有的鸭子都排队了，除了推动服务经纪人的变更通知的方式. 任何帮助/指针都将受到赞赏. 谢谢. n m PS.我确实寻找了类似的帖子，但确实遇到了一些，他们提到的MSDN文章似乎都已删除 - 不确定MSDN网站上发生了什么. 解决方案 对于外部激活器，请查看 microsoft sql"> Server 2008功能包 - " Microsoft SQL Server 2008 R2服务经纪外部激活器". 对于控制台应用程序(处理消息)，好主意是在放置事件通知(
20 2023-04-27
编程技术问答社区
处理Siganlr中的并发连接
我正在使用.NET Framework 4.5.2，我将开始制作一个通知系统，该通知系统将Web应用程序发送到从Windows表单桌面应用程序连接的用户中. 调查后，我发现合适的解决方案正在使用SignalR，因为它支持在将通知发送给连接的客户端之前过滤通知. 但我担心的是: 当我在Web应用程序中创建我的集线器类时，我实现了连接的方法，该方法将检测到连接到服务器以收到通知的任何客户无法在生产中实现的解决方案，因为这是在内存变量(词典)中设置连接用户的可靠的.在我的情况下，连接用户的数量可能为20,000 或结束，将来可能会变大.我需要了解跟踪所有连接用户的最佳方法，同时又有下注方式来处理并发请求而没有任何可扩展性问题.我是新手，我必须做出非常快的决定. 我还需要知道在hub类中可以过度的otreconnect方法的用法. 我还需要知道如何处理连接以在IIS出于任何原因重新启动Internet应用程序的情况下不会丢失. 解决方案 映射连接到与用户可以通过多
16 2023-04-27
编程技术问答社区
为什么我不能有一个Redis客户端在同一连接中充当酒吧和sub?
我的心理模型是"聊天"，我在其中订阅了某个频道，我可以将消息发布到此频道. 解决方案 由于pub/sub是异步的，因此发布的消息可以随时出现，包括当您期望对命令的响应时. 尽管Redis是单线线程，通常可以防止这种事情，但网络延迟可能会引起一些有趣的效果 - 取决于消息的内容，但您可以在服务器实际收到它之前收到对命令的有效响应. 也就脚.但是，只需打开两个与服务器的连接，要容易得多.如果每个客户端都使用两个连接达到连接限制，那么无论如何，每个客户端都可能会遇到一个问题. 其他解决方案 当客户端发出订阅或psubScribe时，该连接将放入" pub/sub"模式中.那时，只有修改订阅集的命令是有效的.当订阅集为空时，连接将重新放回常规模式. 如果您需要在酒吧/子模式中将定期命令发送到Redis，请打开另一个连接.
26 2023-04-27
编程技术问答社区
Sails.js：将用户订阅到一个请求的特定行动中去
在我的帆项目中，我有一个User型号/控制器和Request型号/控制器以及Dashboard控制器.用户可以使用RequestController.create提出数据请求，并且管理员可以使用RequestController.grant. 批准它. 我要做的是在批准其请求之一(更新)时通知用户.在RequestController.grant中，我致电Request.publishUpdate(...)，在我的DashboardController.display中，我致电 Request.find(req.session.user.id, function(err, requests) { ... Request.subscribe(req, requests, ['update']) ... }); 然后，在视图/dashboard/display中，我放入标签: // Socket handl
6 2023-04-27
编程技术问答社区
加入流星与PublishComposite
我从流星应用程序中删除了autopublish.现在，我正在手动出版我的收藏.我有一些相关的收藏.我想尽可能提高性能. 例如，如果我要查看帖子并希望查看与此帖子相关的所有注释，则我必须同时使用post: Posts.findOne(postId)和comments: Comments.find({postId: postId})查询数据库.我正在用iron-router查询数据字段中的两个集合，因此它们存在于我的模板中，但我也在waitOn中订阅了出版物.现在我找到了 https://github.com/englue/englue/meteor-publish-publish-compomposite 这使我可以同时发布多个收藏.但是我不太了解.如果我在server/publish.js中使用Meteor.publishComposite('postAndComments', ...)，请在waitOn中订阅postAndComments，并像我平常一样设置post和data i
18 2023-04-27
编程技术问答社区
热门专题
c# datagridview datasource 集合 @RequestParam 把参数解码成乱码 nfs 共享centos window 数据库是三位小数java获取时过滤0了 maxscript 读取版本 jquery 找到最近的标签 pcs7试用授权删除方法 soci ORM对象关系映射 autofac castle core 代理 前端下载2g大文件导致浏览器奔溃怎么解决 GetTickCount不更新 django 输出访问日志 springmvc vue中子组件的methods中获取到props中的数组 php __wakeup触发__tostring uniapp通过多个页面跳转,不要出现中间页面 rabbitmq清空队列消息 jQuery仿京东多条件分类筛选 webview没网时将错误页 linux中如何查看GDT表项