本周六「上海源创会」,与一线大牛一起聊聊:PHP、Flink、k8s、微服务架构,点击立刻报名!
指数
0
Watch 23 Star 72 Fork 18

keking / kkbidaJava

加入码云
与超过 300 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
解决异构系统间消息通知时保证消息必达 展开 收起

https://github.com/kekingcn/kkbida

克隆/下载
kl 最后提交于 Update README.md
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README.md

kkbida(必达) 消息通知

使用场景

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

外部依赖

准备一个mysql和redis

mysql新建一个数据库callcenterdb

分别配置kk-callcenter-main模块中的 application.properties 配置文件的spring.datasourcespring.redis 开头的配置即可

快速开始

从github拉取代码

git clone https://github.com/kekingcn/kkbida

使用maven构建

cd kkbida
mvn clean install -DskipTests

运行

cd kkbida/kk-callcenter-main/target
java -jar kk-callcenter-main-1.0.0-SNAPSHOT.jar

浏览器访问 http://127.0.0.1:8080 即可 用户名/密码:admin/admin

注意事项

此项目使用了凯京科技另一个开源组件klock( https://gitee.com/kekingcn/spring-boot-klock-starter ),jar包依赖在third-party模块中

系统架构

通过阻塞队列来抗并发,通过延迟队列来处理失败的消息,并辅以控制台手动处理消息来保证消息最终送达。在使用方面,考虑到最小化改造和易用性,提供dubbo和http的sdk客户端

架构拓扑

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;

调用CallBackService发起回调

    Map<String, Object> paramMap = new HashMap<>();
    paramMap.put("city", "上海");
    
    CallBackTask task= new CallBackTask();
    task.setUrl("https://www.apiopen.top/weatherApi"); //回调url(必填)
    task.setRequestMethod(RequestMethodEnum.GET); //请求方式(必填)
    task.setLimitCallCount(3); //重试次数限制(必填)
    task.setExpectResult("成功"); //期待返回结果(必填),用于验证回调是否成功
    task.setSourceAppName("xxx"); //发起发应用名(选填)
    task.setTargetAppName("yyy"); //目标方应用名(选填)
    task.setRequestParam(paramMap); //调用参数(选填)
    String result = callBackService.call(task);

回调发起返回结果说明

调用callBackService.call(task)发起成功则返回一个uuid为taskId,后续可以通过这个taskId查询回调任务详情,示例:'3e41bc91-0707-4b3a-a562-3aec4ed35815'; 发起失败会抛出CallBackException异常

回调失败通知

当回调发起失败次数达到重试限制次数,回调中心会触发webhook发起失败通知

添加webhook钉钉通知操作

详情见:https://open-doc.dingtalk.com/docs/doc.htm?treeId=257&articleId=105735&docType=1 钉钉群添加自定义群机器人

Image text

复制webhook地址

Image text

进入后台管理页面,点击失败通知管理菜单,点击新增webhook在弹出的表单url中粘贴刚刚复制的webhook地址,填入备注保存即可

Image text

添加webhook企业微信通知操作

请参考:https://work.weixin.qq.com/api/doc#90000/90135/90236

联系我们

我们会用心回答解决大家在项目使用中的问题,也请大家在提问前至少Google或baidu过,珍爱生命远离无效的交流沟通

输入图片说明 QQ群号:613025121

点评 ( 2 )

你可以在登录后,发表评论

搜索帮助

14_float_left_people 14_float_left_close