完整英文版 IEC 62541-14:2020 OPC unified architecture - Part 14:PubSub - (OPC 统一架构 - 第 14 部分:PubSub)。IEC 62541-14:2020 定义了 OPC 统一架构 (OPC UA) PubSub 通信模型。它定义了一种 OPC UA 发布订阅模式,该模式补充了 IEC 62541-4 中服务定义的客户端服务器模式。
2022-12-19 16:19:36 13.07MB 62541-14 IEC 架构 OPC
java实现ICE IceStorm pub/sub的demo, 解决topicManager为null的问题
2022-11-07 09:43:54 12.11MB java ice icestorm pub/sub
1
【Azure Developer】使用Azure PubSub服务示例代码时候遇见了.NET 6.0的代码转换问题.doc
2022-07-10 14:06:01 1016KB 技术资料
ipc-pubsub 具有发布者/订阅者接口的POSIX共享内存上的简化IPC。 设计须知 思想 Unix / Posix队列需要调整以具有合理数量的可用文件描述符。 我希望不要这样。 UDP需要正确的网络设置,这似乎并不理想 信号量不允许任何数据,这意味着必须通过复杂的共享内存结构(包括有关可用节点的元数据)发送所有实际有效载荷 管道的状态有些复杂,可能导致虚假阻塞管道中的数据过多 设计 单个共享内存对象保留有索引和运行中消息 添加节点 写锁定元数据文件 读取当前的元数据 将节点信息附加到数据 写元数据 解锁元数据文件 发送信息 (可选)检索并使用shm缓冲区:: Allocate()-> ShmBuffer(); Send(ShmBuffer)或Send(data,len) 写锁定元数据文件 读取当前的元数据 附加到适当的飞行队列 解锁元数据文件 sem_up()在所有读者上
2022-05-09 23:23:04 38KB C++
1
1、基于spring-boot-starter-data-redis实现发布订阅功能 2、依赖的 spring-boot-starter-parent 的版本是 2.5.3 3、如果用IDEA打开后,@Slf4j报错的话,请下载插件 Lombok 详细的功能介绍可以参考这篇博客 https://blog.csdn.net/zzy893037505/article/details/122585039
2022-01-19 19:01:53 124KB redis spring boot 数据库
1
AMQP 简单的发布订阅 使用AMQP消息传递在服务之间交换数据的 Pub Sub 系统。 使用 您的项目至少需要使用 Node 版本 10,最好使用 Node 14 (LTS) 或更高版本。 npm install amqp-simple-pub-sub 创建发布者 const { makePublisher } = require ( 'amqp-simple-pub-sub' ) const publisher = makePublisher ( { exchange : 'testService' } ) 发布消息 await publisher . start ( ) publisher . publish ( 'test' , 'Hello World' ) 创建订阅者 const { makeSubscriber } = require ( 'amqp-simple-
2021-07-24 16:03:47 198KB amqp pubsub message-queue JavaScript
1
txtsub txtsub 是带有文本文件的 Node.js 的 Pub/sub。 例子 var client = require ( "txtsub" ) ; var sub = client ( ) ; sub . subscribe ( "test.txt" , function ( data ) { console . log ( "alltext" , data . raw ) ; console . log ( "diff" , data . diff ) ; } ) ; var pub = client ( ) ; setTimeout ( function ( ) { pub . publish ( "test.txt" , "hello" ) ; // "sub hello" } , 1000 ) ; 安装 npm install txtsub 错误处理 v
2021-07-09 19:02:54 3KB JavaScript
1
全面:tigase 完全实现了XMPP协议,除了全面实施的两个核心协议,它支持大多数的你可能永远都需要的扩展协议。 开源:Tigase是开源的,如果你有有那能力,你可以定制自己的XMPPServer,虽然经过了很多次此时,但是仍然有可能有bug,你可以修补bug并提交代码到官方。 可靠:Tigase在设计的时候已经充分的考虑到他的容错能力,它的代码可以自动处理错误保证你的应用尽可能的不down掉。它已经被部署在很多企业的生产环境!并且被测试通过 集群支持:Tigase支持集群,通过集群多个节点在一块,支持百万级用户并发,Seesmic是最好的例子。 性能和效率:单cpu 单用户连接,只需要10kb的内存就可以处理10000个数据包,安装Tigase的时候已经知道,Tigase支持单机50W并发,另外,Tigase还可以部署在只有10M内存的机器上。Tigase支持虚拟域,单服务器可以安装多个域 监控策略:Tigase提供很多开箱即用的自我监控功能。你可以通过XMPP,JMX,Http和SNMP查看服务运行时的错误。 可扩展:设计之初,Tigase就是可扩展的,支持自定义插件,开发者可以很轻松的扩展他的功能。插件开发,Tigase支持多种语言,Groovy(建议),Scala,Python,Ruby。
2021-06-26 18:00:52 68.28MB JAVA XMPP Tigase tigase-server8.0
1
小酒吧 tiny-pubsub是一个使用javascript编写的超级简单的事件管理包,没有依赖项。 现在tiny-pubsub是827个字节。 这绝不是要取代rxjs。 这是一个小型的,同步运行的,功能轻的事件驱动的编程库。 RxJs是功能齐全的事件驱动编程库。 安装 npm install --save tiny-pubsub 用法 该api仅具有三个功能。 publish , subscribe和unsubscribe 。 event_definitions.js // Using object singletons is a good way to register events. const CHATROOM_JOIN = { } ; export { CHATROOM_JOIN } app.js import { subscribe , publish , unsu
2021-03-11 11:07:00 3KB JavaScript
1