文件名称：kiteq:kiteq是一个分布式mq框架
文件大小：1.34MB
文件格式：ZIP
更新时间：2024-05-27 17:09:27
golang notify mq 2pc Go
KiteQ 基于go+protobuff实现的多种持久化方案的mq框架 WIKI() 简介 * 基于zk/etcd维护发送方、订阅方、broker订阅发送关系、支持水平、垂直方面的扩展 * 基于与topic以及第二级messageType订阅消息 * 基于mysql、文件存储方式多重持久层消息存储 * 保证可靠异步投递 * 支持两阶段提交分布式事务 * 自定义group内的Topic级别的流控措施，保护订阅方安全 * kiteserver的流量保护 * 客户端连接上报系统预热时间，根据预热时间逐步放量推送消息 * Client Supported：Java、Go、CPP、PHP 工程结构 kiteq/ ├── README.md ├── conf 配置信息 ├── log log4go的配置 ├── build.sh
【文件预览】：
kiteq-master
----exchange()
--------bind_exchanger.go(9KB)
--------bind_exchanger_test.go(3KB)
----log()
--------log.xml(6KB)
--------log_test.xml(5KB)
----server()
--------kiteq_server.go(8KB)
--------recover_manager.go(3KB)
--------kite_server_config_test.go(219B)
--------recover_manager_test.go(3KB)
--------kite_server_config.go(5KB)
--------kiteq_server_monitor.go(4KB)
----handler()
--------validate_event.go(1KB)
--------delivery_registry_test.go(1KB)
--------access_event.go(2KB)
--------accept_event.go(3KB)
--------pipe_events.go(6KB)
--------remote_future.go(1KB)
--------deliver_pre.go(5KB)
--------tx_ack.go(2KB)
--------deliver_result.go(7KB)
--------deliver_qos.go(2KB)
--------delivery_registry.go(859B)
--------packet_decode.go(3KB)
--------check_msg.go(4KB)
--------heartbeat.go(1KB)
--------persistent_msg.go(4KB)
----conf()
--------.DS_Store(6KB)
--------cluster.toml(2KB)
----tools()
--------kite_store_tools.go(564B)
----doc()
--------kiteq_dep.png(32KB)
--------qcode.png(76KB)
--------kiteq.001.png(1001KB)
--------communicate_protocol.png(121KB)
--------kiteq_arch.png(58KB)
--------logo.jpg(12KB)
--------kiteq_arch.graffle(11KB)
----.gitignore(322B)
----go.sum(13KB)
----README.md(6KB)
----kiteq.go(1KB)
----kiteq.sh(282B)
----build.sh(543B)
----go.mod(559B)
----store()
--------memory()
--------kite_store.go(3KB)
--------mysql()
--------file()
--------parser()
--------kite_mock_store.go(3KB)