PHP-BeanStalk是基于C开发的支持PHP5和PHP7的BeanStalkd扩展,此扩展相对php书写的客户端性能提升一倍左右 实现了对BeanStalkd协议的支持。BeanStalkd是一个高性能的队列服务器,而当前的php客户端性能略低,故提供了此beanstalk的php客户端。该客户端提供了支持操作系统windows x86/x64, linux/unix/osx以上平台皆通过测试
# JMS/消息中间件
mpush,是一款开源的实时消息推送系统,采用java语言开发,服务端采用模块化设计,具有协议简洁,传输安全,接口流畅,实时高效,扩展性强,可配置化,部署方便,监控完善等特点。同时也是少有的可商用的开源push推送系统。
基于giiwa框架的ActiveMQ模块,http://giiwa.org,提供ActiveMQ的基本配置管理,并向其他模块提供MQ API,以实现分布式处理和简化其他模块的开发。
基于 giiwa 框架的 Message 模块关于giiwa, 请参阅http://giiwa.org. 内部消息系统模块,提供的后台管理,并向其他模块提供Message API和widget。开发使用下载所有源码,然后直接导入Eclipse, 修改...进入项目目录, 直接运行 ant编译打包, 会生成 message_1.0.1_????在你安装的giiwa 服务器中, 进入后台管理->系统管理->模块管理->上传模块,然后重启giiwa. 重启后,进入后台管理->消息管理-&g
nredis-proxy 是一个以redis 协议为主的高性能稳定的代理中间件服务,不侵入业务代码,与业务毫无联系,不需要改任何应用代码,天然支持分布式部署。
zcmsZCMS是基于JAVA nio 方式进行开发,其设计目标,是搭建快速,修改容易,轻量级,易拓展,支持集群和分布式,可根据公司需求,定制开发;执行效率极高,单实例支持10000人同时在线聊天;解决了tcp连接中断,粘包等问题;
Kafka-php 使用纯粹的 PHP 编写的 kafka 客户端,目前支持 0.8.x 以上版本的 Kafka,该项目 v0.2.x 和 v0.1.x 不兼容,如果使用原有的 v0.1.x 的可以参照文档Kafka PHP v0.1.x Document, 不过建议切换到 v0.2.x 上。v0.2.x 使用 PHP 异步执行的方式来和kafka broker 交互,较 v0.1.x 更加稳定高效, 由于使用 PHP 语言编写所以不用编译任何的扩展就可以使用,降低了接入与维护成本。Installation
burrowx Kafka 状态信息监视器
# JMS/消息中间件 # 管理和监控
DBus 专注于数据的收集及实时数据流计算,通过简单灵活的配置,以无侵入的方式对源端数据进行采集,采用高可用的流式计算框架,对在业务流程中产生的数据进行汇聚,经过转换处理后成为统一 JSON 的数据格式,提供给不同数据使用方订阅和消费,充当数仓平台、大数据分析平台、实时报表和实时营销等业务的数据源。DBus 将 UAV 采集的全维监控数据以无侵入方式进行实时收集,为下游大数据处理平台 Wormhole 运行统计模型和机器学习提供数据源。
WMQ 基于 RabbitMQ 实现的消息中间件
WQS 是微博开源的消息服务中间件。功能特性多租户支持;支持 pub/sub、long polling、pipeline;多 IDC 部署WQS 目前支持多 IDC 部署,创建队列时选取响应的配置表明该队列是否需要多 IDC 功能支持,当 WQS 集群跨 IDC 部署时:。当 Queue 配置多 IDC 同步时,该实例会从用户所配置的 IDC 内的 Kafka 集群上读取消息,且不同 IDC 的 WQS 实例读取同一 Kafka 集群时,会采用相同的 consumer-group-ID。
php-nsqphp-nsq 是nsq的php客户端,采用c扩展编写,性能和稳定性。});Nsq 类方法:connectNsqdpub的时候连接nsq,你也可以利用此函数做健康检查。touch如果你消息执行太长,可以利用次函数告知nsq 你还活着,一般用于执行频率比较规律的场景。
在所有这些用例中,你将看到 Spring Framework 中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。
MqttWk基于 nutzboot + netty或t-io + redis + kafka 实现的MQTT服务broker. 本项目代码主要来源于 netty/t-io/iot-mqtt-server 等众多项目,开源免费,欢迎交流学习。├──mqtt-test-websocket--websocket通信测试示例功能说明参考MQTT3.1.1规范实现。mqtt-broker 下执行mvn clean package nutzboot:shade进行打包。自定义 - 连接认证默认只是简单使用对用户名进行R
KafkaBridge 是奇虎 360 开源的 Kafka 客户端 SDK ,底层基于 librdkafka ,与之相比封装了大量的使用细节,简单易用,使用者无需了解过多的 Kafka 系统细节,只需调用极少量的接口,就可完成消息的生产和消费。此外,针对使用者比较关心的消息生产的可靠性,作了近一步的提升。针对高级用户,支持通过配置文件调整所有的 librdkafka 的配置;在非按 key 写入数据的情况下,尽最大努力将消息成功写入;在 php-fpm 场景中,复用长连接生产消息,避免频繁创建断开连接的开销
Hmily 是一款高性能分布式事务 tcc 开源框架。基于java语言来开发,支持 Dubbo、Spring Cloud、Motan 等 RPC 框架进行分布式事务。采用disruptor框架进行事务日志的异步读写,与RPC框架的性能毫无差别。支持SpringBoot-starter 项目启动,使用简单。本地事务存储支持 : redis,mongodb,zookeeper,file,mysql。
QMQ 是去哪儿网内部广泛使用的消息中间件,自2012年诞生以来在去哪儿网所有业务场景中广泛的应用,包括跟交易息息相关的订单场景; 也包括报价搜索等高吞吐量场景。目前在公司内部日常消息 qps 在 60W 左右,生产上承载将近 4W+ 消息 topic ,消息的端到端延迟可以控制在 10ms 以内。
kkbida(必达) 消息通知使用场景解决异构系统间消息通知时保证消息必达,常见于系统回调,消息异步通知等场景,提供了失败重试,错误通知,最终手动补偿,web端管理等功能。通过阻塞队列来抗并发,通过延迟队列来处理失败的消息,并辅以控制台手动处理消息来保证消息最终送达。在使用方面,考虑到最小化改造和易用性,提供dubbo和http的sdk客户端。当消息重试最大次数失败后,可设置webhook通知到钉钉等通讯平台上及时处理。
WePush 消息批量推送工具
# 网络工具包 # JMS/消息中间件
由 Apache RocketMQ 社区贡献并维护的 Apache RocketMQ 扩展项目。详细介绍请查看README. RocketMQ-DockerApache RocketMQ Docker 提供了 Dockerfile 和 bash 脚本用于构建和运行 Docker 镜像。RocketMQ-MySQL该项目是 MySQL 和其他系统之间的数据复制器。其他RocketMQ-Druid,RocketMQ-Ignite和RocketMQ-Storm的集成
# JMS/消息中间件 # 其他开发相关
安科网(Ancii),中国第一极客网
Copyright © 2013 - 2019 Ancii.com
京ICP备18063983号-5 京公网安备11010802014868号