1、国内主流企业即时通讯
- 企业微信：腾讯出品，和微信互通；聊天、审批、打卡、会议、客户联系（客户朋友圈）、应用接入；支持私有化部署。适合绝大多数国内大中小微企业，客户运营场景优势明显。
- 钉钉：阿里，强 OA 工作流：审批、考勤、钉盘、钉会议、宜搭低代码；功能重管理。制造业、传统企业、行政流程多的企业使用广泛。
- 飞书：字节跳动，文档深度集成，会议、多维表格、知识库，适合知识型团队、互联网、研发团队。
本文主要讲解用户可以通过 REST API 或钉钉机器人消息触发 MR 的批准、拒绝、关闭以及创建 Tag 等操作。
2、流程图
- 研发人员提出合并请求url，将合并请求发给审核者。
- 审核者通过钉钉发送"同意合并url"，即可合并程功。
3、实现代码
依赖
<dependency> <groupId>org.gitlab4j</groupId> <artifactId>gitlab4j-api</artifactId> <version>${gitlab4j-api.version}</version> </dependency> <dependency> <groupId>com.dingtalk.open</groupId> <artifactId>dingtalk-stream</artifactId> <version>${dingtalk-stream.version}</version> </dependency>应用配置（application.yaml）
audit: gitlab: base-url: http://127.0.0.1:8090 # GitLab 服务器地址 token: glpat-xxxxxxxxxxxx # GitLab Personal Access Token ding: talk: robot: client-id: dingxxxxxxxxxxxx # 钉钉机器人 ClientID client-secret: xxxxxxxxxxxxxxxx # 钉钉机器人 ClientSecret钉钉监听核心代码
/** * 启动 Stream 客户端，监听机器人回调消息 */ @PostConstruct public void start() { if (!properties.isEnabled()) { log.info("钉钉机器人 Stream 监听已禁用 (dingtalk.robot.enabled=false)"); return; } streamThread = new Thread(this::doStartStreamClient, "dingtalk-robot-stream"); // 设置为守护线程，避免应用退出时 Stream 客户端未正常关闭 streamThread.setDaemon(true); streamThread.start(); log.info("钉钉机器人 Stream 客户端已启动, topic={}", properties.getTopic()); } /** * 启动 Stream 客户端，监听机器人回调消息 */ private void doStartStreamClient() { try { streamClient = OpenDingTalkStreamClientBuilder .custom() .credential(new AuthClientCredential(properties.getClientId(), properties.getClientSecret())) .registerCallbackListener(properties.getTopic(), (ChatbotMessage message) -> { //1、 处理消息，开发者根据自身业务需求，处理机器人回调 String result = handleMessage(message); //2、回复消息 reply(message, result); return new JSONObject(); }) .build(); // start() 为阻塞方法，需在独立线程中执行 streamClient.start(); } catch (Exception e) { log.error("钉钉机器人 Stream 客户端异常", e); } } /** * 处理消息 * * @param message 收到消息 * @methodName: handleMessage * @return: java.lang.String * @author: ybw * @date: 2026/7/28 **/ private String handleMessage(ChatbotMessage message) { //1、 获取钉钉消息内容 String content = message.getText().getContent(); //2、判断是否有"同意合并"关键字 if (!content.contains("同意合并")) { //2.1 不包含 return "没有同意合并关键字"; } //2.2 包含 //2.2.1 获取合并链接地址 String mergeRequestUrl = MyStrUtil.getMergeRequestUrl(content); log.info("合并请求地址：{}", mergeRequestUrl); if (StrUtil.isBlank(mergeRequestUrl)) { return "无合并请求链接地址"; } //2.2.2 发送合并请求 ApproveByUrlRequest request = new ApproveByUrlRequest(mergeRequestUrl); AuditResult auditResult = auditService.approveMrByUrl(request); return auditResult.getMessage(); } /** * 回复消息 * * @param message 收到消息 * @param result 处理结果 * @methodName: reply * @return: void * @author: ybw * @date: 2026/7/28 **/ private void reply(ChatbotMessage message, String result) { try { //1、 使用 sessionWebhook 回复消息 String sessionWebhook = message.getSessionWebhook(); if (StrUtil.isBlank(sessionWebhook)) { return; } //2、回复消息，使用 sessionWebhook 回复消息 BotReplier replier = new BotReplier(sessionWebhook); replier.replyText("处理结果：" + result); log.info("已通过 sessionWebhook 回复消息"); } catch (Exception e) { log.error("reply error", e); } } /** * 停止 Stream 客户端 */ @PreDestroy public void stop() { if (streamClient != null) { try { streamClient.stop(); log.info("钉钉机器人 Stream 客户端已关闭"); } catch (Exception e) { log.error("关闭 Stream 客户端失败", e); } } if (streamThread != null && streamThread.isAlive()) { streamThread.interrupt(); } }审核核心代码
/** * 通过 MR 链接地址批准 MR */ public AuditResult approveMrByUrl(ApproveByUrlRequest request) { // 1. 解析 URL，提取项目路径和 MR IID GitLabApiClient.MrUrlInfo urlInfo = gitLabApiClient.parseMrUrl(request.getMrUrl()); log.info("解析 MR URL: projectPath={}, mrIid={}", urlInfo.projectPath(), urlInfo.mrIid()); // 2. 将项目路径解析为项目 ID Long projectId = gitLabApiClient.resolveProjectId(urlInfo.projectPath()); // 3. 委托给现有的 approveMr 逻辑 ApproveRequest approveRequest = new ApproveRequest(); approveRequest.setProjectId(projectId); approveRequest.setMrIid(urlInfo.mrIid()); return approveMr(approveRequest); }4、使用
- 钉钉用户发送：同意合并：http://172.168.0.2/test/git-audit/-/merge_requests/1
- 钉钉返回消息：处理结果：MR 已批准并合并。