kkbida 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
kkbida 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议 Apache
开发语言 Java
操作系统 跨平台
软件类型 开源软件
开发厂商
地区 国产
提 交 者 凯京技术团队
适用人群 未知
收录时间 2019-03-14

软件简介

kkbida(必达) 消息通知

使用场景

解决异构系统间消息通知时保证消息必达,常见于系统回调,消息异步通知等场景,提供了失败重试,错误通知,最终手动补偿,web端管理等功能。

系统架构

项目采用spring boot构建,使用spring session redis分布式session,支持分布式多机部署。通过阻塞队列来抗并发,通过延迟队列来处理失败的消息,并辅以控制台手动处理消息来保证消息最终送达。在使用方面,考虑到最小化改造和易用性,提供dubbo和http的sdk客户端。当消息重试最大次数失败后,可设置webhook通知到钉钉等通讯平台上及时处理。

架构拓扑

Image text

SDK使用方法

maven引入sdk

        <dependency>
            <groupId>cn.keking.callcenter</groupId>
            <artifactId>kk-callcenter-sdk</artifactId>
            <version>1.0.0-SNAPSHOT</version>
        </dependency>

获取CallBackService对象

dubbo方式

    @Reference(version = "1.0")
    private CallBackService callBackService;
    

http方式

推荐获取方式如下(也可以直接new) ps:如果通过http客户端sdk调用,需要先申请配置白名单

    @Value("${callBack.BaseUrl}")
    private String callBackBaseUrl; //回调中心http调用url
    @Value("${callBack.UserName}") 
    private String callBackUserName; //回调中心帐号
    @Value("${callBack.PassWord}")
    private String callBackPassWord; //回调中心密码
    
    @Bean
    public CallBackService callBackService(){
        CallBackServiceHttpImpl callBackServiceHttp = new CallBackServiceHttpImpl(callBackBaseUrl,callBackUserName,callBackPassWord);
        return callBackServiceHttp;
    }
    
    @Autowired
    private CallBackService callBackService;
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (5)

加载中

引用来自“chuanshi88”的评论

这个图是用啥画的。。。
visio
2019/03/15 11:50
回复
举报
这个图是用啥画的。。。
2019/03/15 10:45
回复
举报

引用来自“tkggusraqk”的评论

既然都用队列了,还阻塞,用来抗高并发,不如去掉阻塞
阻塞队列是指队列为空时取数据阻塞和队列满的时候添加数据阻塞,redis默认队列长度为4294967295,只要redis实例内存容量够,添加数据就不会阻塞,和抗迸发不冲突
2019/03/15 09:29
回复
举报
开源必点赞
2019/03/15 09:20
回复
举报
既然都用队列了,还阻塞,用来抗高并发,不如去掉阻塞
2019/03/15 08:07
回复
举报
更多评论
2019/07/11 09:12

kkbida 1.0.0 发布,微服务场景下消息通知必达中间件

项目简介 本项目为我司(凯京科技)内部开发的,用于【处理各服务间回调通知】的中间件,经过我司内部半年多生产环境稳定使用后,开源出来回馈社区 使用场景 解决异构系统间消息通知时保证消息必达,常见于系统回调,消息异步通知等场景,提供了失败重试,错误通知,最终手动补偿,web端管理等功能 项目地址:https://g...

2
31
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
2019/03/15 13:46

kkbida - 开源消息投递中间件详细解析

kkbida - 开源消息投递中间件详细解析 项目简介 kkbida为凯京科技开源的消息投递中间件,谐音必达,旨在保证异构系统间消息通知时消息投递必达,详情见 https://gitee.com/kekingcn/kkbida 快速开始 从gitee拉取代...

0
4
2019/03/22 13:41

RabbitMQ通过HTTP API获取队列消息内容

RabbitMQ通过HTTP API获取队列消息内容 背景 为配合公司数据中台建设,我们对公司内部使用的mysql binlog数据分发中间件(现已开源:https://gitee.com/kekingcn/keking-binlog-distributor )进行定制化改造,使...

2
2
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
5 评论
80 收藏
分享
返回顶部
顶部