Fast-cast 高性能的低延迟可靠多播消息开源项目

我要开发同款
匿名用户2017年12月22日
175阅读

技术信息

开源地址
https://github.com/RuedigerMoeller/fast-cast
授权协议
LGPL

作品详情

基于主题的高性能、可靠无代理UDP消息传递(“事件总线”)。可承受每秒高达700万个70字节的消息。

实现 NAK协议所需的缓冲区不受影响,因此对GC的影响不大。如果配置得当,能保证可靠、有边界的低延迟。

要求JDK1.7或更高版本

示例代码

基于快速序列化的对象组播(=广播)发布者:

public static void mai(Strig arg[]) {        FastCast.getFastCast().setNodeId("PUB"); // 5 chars MAX !!        cofigureFastCast();        FCPublisher pub = FastCast.getFastCast().oTrasport("default").publish(            ew PublisherCof(1)            // uique-per-trasport topic id                .umPacketHistory(40_000)   // uber of packets kept for retrasmissio requests                .pps(5000)                  // packets per secod rate limit. So max traffic for topic = 5000*2500 = 12.5 MB/secod        );        // use a helper for fast-serialized messages        ObjectPublisher opub = ew ObjectPublisher(pub);        RateMeasure measure = ew RateMeasure("msg/s");        while( true ) {            measure.cout();            opub.sedObject(                ull,  // all listeers should receive (by specifyig a odeId, a specific subscriber ca be targeted)                "Hello "+System.curretTimeMillis(), // serializable object                false  // allow for 'batchig' several messages ito oe (will create slight latecy)            );        }    }

功能介绍

基于主题的高性能、可靠无代理 UDP 消息传递(“事件总线”)。可承受每秒高达 700 万个 70 字节的消息。 实现 NAK 协议所需的缓冲区不受影响,因此对 GC 的影响不大。如果配置得当,...

声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态

评论