机器人接收消息

<dependency>
  <groupId>com.dingtalk.open</groupId>
  <artifactId>app-stream-client</artifactId>
  <version>{sdk-version}</version>
</dependency>

public class BotExample {
  
  
  public static void main(String[] args) {
    OpenDingTalkClient client = OpenDingTalkStreamClientBuilder
                .custom()
                .credential(new AuthClientCredential("${ClientId}", "${ClientSecret}"))
                .registerCallbackListener("${topic}", new RobotMsgCallbackConsumer())
                .build();
     client.start();
  }
  
  
  public static class RobotMsgCallbackConsumer implements OpenDingTalkCallbackListener<JSONObject, JSONObject> {
    
    /*
     * @param request
     * @return
     */
    @Override
    public JSONObject execute(JSONObject request) {
        System.out.println(JSON.toJSONString(request));
        try {
            JSONObject text = request.getJSONObject("text");
            if (text != null) {
                //机器人接收消息内容
                String msg = text.getString("content").trim();
                String openConversationId = request.getString("conversationId");
            }
        } catch (Exception e) {
            log.error("receive group message by robot error:" +e.getMessage(), e);
        }
        return new JSONObject();
    }
  } 
}

{
  "conversationId": "cidjMOsz******AhS4Jg==",
  "atUsers": [
    {
      "dingtalkId": "$:LWCP_v1:$v*********f1+2ow21Zzg"
    }
  ],
  "chatbotCorpId": "ding9f50*****6741",
  "chatbotUserId": "$:LWCP_v1:$v*********1+2ow21Zzg",
  "msgId": "msg2*****p+w==",
  "senderNick": "小钉",
  "isAdmin": true,
  "senderStaffId": "452523285939877041",
  "sessionWebhookExpiredTime": 1695204671648,
  "createAt": 1695199269062,
  "senderCorpId": "ding9f50*****6741",
  "conversationType": "2",
  "senderId": "$:LWCP_v1:$C*********pnNGsP0HS+",
  "conversationTitle": "统一应用模型-测试群",
  "isInAtList": true,
  "sessionWebhook": "https://oapi.dingtalk.com/robot/sendBySession?session=c610ee93e4d96899d9236bd4bea185dd",
  "text": {
    "content": " 你好"
  },
  "robotCode": "ding1f*******dabddc",
  "msgtype": "text"
}

@RestController
public class RobotsController {
  	// 下方 value = "/robots", 决定下方设置机器人消息接收地址，例如：https://example.com/robots
    @RequestMapping(value = "/robots", method = RequestMethod.POST)
    public String helloRobots(@RequestBody(required = false) JSONObject json) {
        System.out.println(json);
      	//机器人接收消息内容
        String content = json.getJSONObject("text").get("content").toString().replaceAll(" ", "");

        return null;
    }
}

{
  "conversationId": "cidjMOsz******AhS4Jg==",
  "atUsers": [
    {
      "dingtalkId": "$:LWCP_v1:$v*********f1+2ow21Zzg",
      "staffId": "452523285939877041"
    }
  ],
  "chatbotCorpId": "ding9f50*****6741",
  "chatbotUserId": "$:LWCP_v1:$v*********1+2ow21Zzg",
  "msgId": "msg2*****p+w==",
  "senderNick": "小钉",
  "isAdmin": true,
  "senderStaffId": "452523285939877041",
  "sessionWebhookExpiredTime": 1695204671648,
  "createAt": 1695199269062,
  "senderCorpId": "ding9f50*****6741",
  "conversationType": "2",
  "senderId": "$:LWCP_v1:$C*********pnNGsP0HS+",
  "conversationTitle": "统一应用模型-测试群",
  "isInAtList": true,
  "sessionWebhook": "https://oapi.dingtalk.com/robot/sendBySession?session=c610ee93e4d96899d9236bd4bea185dd",
  "content": " 你好"
  "msgtype": "text"
}