投稿
  1. 极安网首页
  2. 网络安全新闻

Java项目实现消息推送到团队微信，让项目“会说话”

作者：Admin • 发布： • 栏目：网络安全新闻

作者：Mintimate

博客：https://www.mintimate.cn

Mintimate's Blog，只为与你分享

封面嗷

前言

消息推送到团队微信，很多人看了标题，可能不能理解什么意思，其实：

  • 消息：工程项目内的提示消息，比如：项目关联的OCR识别次数接口告罄通知、项目均衡过载通知等消息。
  • 团队微信：企业微信或关联企业微信的个人微信，用于接受消息。

通过上述描述，大家是不是就更能理解了呢？所以，我们项目“说话”，就是让我们Java项目日常使用过程中，一些时间触发时，使用API推送消息至开发者/团队的微信，方便团队维护。类似邮件提醒⏰。

本文推送是直接内置到Java项目内，如：Springboot项目后端。如果需单独搭建推送服务，给其他工程使用，可以使用PHP进行搭建：

  • 【Web Function】实战使用：PHP Web函数搭建推送服务，轻松推送消息至个人微信

推送服务

具体来说，推送服务的思路是这样的：

推送服务逻辑

实际的项目中，也可以使用：

场景1：API服务告罄警告

有时候，我们搭建一些项目，会直接使用外部API除了图片。比如：使用腾讯云万象数据，识别图片分类

识别图片分类

这样的接口，肯定是有使用次数限制，在次数快使用完毕，就可以创建一个方法，直接调用实现写好的工具包方法，对微信发送消息：

API使用告罄提醒

场景2：数据库"灾变"

Java作为一门后端语言，数据库的重要性不用多说。如果数据库服务器崩溃了，肯定是要第一时间处理。我们可以写一个监听，来观察数据库的“存活”：

数据库“灾变”提醒

前期准备

前期准备很简单，主要是

  • Java依赖包：Fastjson、springframework-Web
  • 微信推送接口申请

Java依赖包

1. Fastjson包

在Maven内，加入Fastjson的包：

添加Fastjson包

     com.alibaba
     fastjson
     1.2.75

如果你项目并没有使用Maven进行项目包管理，需要手动下载Fastjson，并添加至项目依赖内：

  • Fastjson项目发布地址

使用Fastjson，主要是用于处理JSON对象。比如：JSON对象封装、JSON和String互转以及JSON对象解析等。

2. springframework

直接应用springframework的包，主要是想偷懒…… 如果你有更简单的方法实现包含header的HTTP请求，也可以不用springframework的包：

       org.springframework
       spring-web
       5.3.3

微信推送接口申请

微信接口申请，实际上是申请企业微信的接口。但是个人也可以申请。（且后期可以选择推过微信接收推送，实际上不需要多下载安装一个企业微信在手机上。）

1. 应用创建

进入企业微信官网，注册一个企业微信。创建好后。我们选择应用管理，并创建一个应用：

创建应用

2. 获取AgentId和Secret

创建好后，我们获取应用AgentId和Secret：

获取AgentId和Secret

3. 获取企业ID

进入我的企业页面，拉到最下边，可以看到企业ID：

企业ID

4. 绑定个人微信

如果你并不想保留企业微信在手机上，想直接推送消息到自己的个人微信，可以进入「我的企业」 → 「微信插件」，拉到下边扫描二维码，关注以后即可收到推送的消息:

绑定个人微信

通讯原理

综上，你应该在项目内添加了Fastjson，并申请微信接口，得到参数：

  • WECOM_CID：上文步骤中获取的企业ID
  • WECOM_SECRET：上文步骤中获取的应用Secret
  • AGENT_ID：上文步骤中获取的应用AgentId

之所以需要上述消息，主要是用于token的生成，可以看微信开发者文档：

  • 企业微信开发API
开发文档

而有了token，才可以对微信进行推送。进一步，系统工作时候的原理：

系统工作原理

代码实现

1. 静态属性

我们创建了一个工具类，因为实际使用，肯定是作为一个静态方法使用，不用实例对象。所以，我们创建静态方法：

    // 微信接口获取
    final static String GET_ACCESS_TOKEN_URL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";
    // 个人企业微信接口参数
    final static String SEND_MESSAGE_URL = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
    // 企业微信公司ID
    final static String WECOM_CID = "";
    // 企业微信公司密钥
    final static String WECOM_SECRET = "";
    // 应用ID
    final static String AGENT_ID = "";
    // 发送用户，@all代表企业微信里所有人
    final static String TOUSER = "@all";  
    
    
    // 发送失败
    final static int ERROR_CODE=0;
    // 发送成功
    final static int SUCCESS_CODE=0;
    // 发送状态
    static int STATUS_CODE=ERROR_CODE;

当然，我这边的状态写的可能比较少，所以只写了2个状态。大家后续可以自行更改。另外大家记得填入自己企业微信的WECOM_CID、WECOM_SECRET、AGENT_ID。

2. Token申请

静态方法内，我已经提前定义Token申请的地址，我们只需要封装参数为JSON，对其请求即可：

// 微信接口获取
    final static String GET_ACCESS_TOKEN_URL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";

我们使用RestTemplate发起HTTP请求，先定义一个通用包，用于后续复用：

// HTTP请求发送
private static String HttpRestClient(String url, HttpMethod method, JSONObject json) throws IOException {
        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
        requestFactory.setConnectTimeout(10 * 1000);
        requestFactory.setReadTimeout(10 * 1000);
        RestTemplate client = new RestTemplate(requestFactory);
        HttpHeaders headers = new HttpHeaders();
        MediaType type = MediaType.parseMediaType("application/json;charset=UTF-8");
        headers.setContentType(type);
        HttpEntity requestEntity = new HttpEntity(json.toString(), headers);
        //  执行HTTP请求
        ResponseEntity response = client.exchange(url, method, requestEntity, String.class);
        return response.getBody();
    }

之后，写一个方法对其调用：

private static int sendMessage(String sendText, String access_token) {
    String url = SEND_MESSAGE_URL + access_token;
    HttpMethod method = HttpMethod.POST;
    JSONObject json = new JSONObject();
    JSONObject jsonText = new JSONObject();
    jsonText.put("content", sendText);
    json.put("touser", TOUSER);
    json.put("agentid", AGENT_ID);
    json.put("msgtype", "text");
    json.put("text", jsonText);
    //发送http请求并返回结果
    try {
        String result = sendMessageToWechat.HttpRestClient(url, method, json);
        JSONObject obj = JSON.parseObject(result);
        //将Json字符串转化为Json对象
        if ((int) obj.get("errcode") == 200) {
            //从Json对象中提取键值为“status”的键值对，并将键值保存在“status”字符串中
            STATUS_CODE = SUCCESS_CODE;
        }
    }
    catch (IOException e) {
        e.printStackTrace();
    }
    return STATUS_CODE;
}

测试一下：

获取Token成功

3. 携带Token发送消息

首先，创建一个私有方法，对Token和SEND_MESSAGE_URL(https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=)组合的链接?，发送content对象。而这个content需要和其他参数组合为JSON对象，其结构：

JSON对象结构

用Fastjson来组合JSON对象很简单：

JSONObject json = new JSONObject();
JSONObject jsonText = new JSONObject();
jsonText.put("content", sendText);
json.put("touser", TOUSER);
json.put("agentid", AGENT_ID);
json.put("msgtype", "text");
json.put("text", jsonText);

用上问提到的方法，再次发送POST请求即可：

private static int sendMessage(String sendText, String access_token) {
	String url = SEND_MESSAGE_URL + access_token;
	HttpMethod method = HttpMethod.POST;
	JSONObject json = new JSONObject();
	JSONObject jsonText = new JSONObject();
	jsonText.put("content", sendText);
	json.put("touser", TOUSER);
	json.put("agentid", AGENT_ID);
	json.put("msgtype", "text");
	json.put("text", jsonText);
	//发送http请求并返回结果
	try {
		String result = sendMessageToWechat.HttpRestClient(url, method, json);
		JSONObject obj = JSON.parseObject(result);
		//将Json字符串转化为Json对象
		if ((int) obj.get("errcode") == 200) {
			//从Json对象中提取键值为“status”的键值对，并将键值保存在“status”字符串中
			STATUS_CODE = SUCCESS_CODE;
		}
	}
	catch (IOException e) {
		e.printStackTrace();
	}
	return STATUS_CODE;
}

理论上，这个方法执行成功，消息就可以直接发送了。但是，这个未来作为系统的工具包，不用去实例，我们再写一个方法封装一下：

public static int sendText(String Text) {
    if (Text == null) {
        return ERROR_CODE;
    }
    String access_token = getAccessToken();
    if (access_token == null || access_token.equals("")) {
        return ERROR_CODE;
    } else {
        sendMessage(Text, access_token);
    }
    return STATUS_CODE;
}

这样，Controller层，就可以直接调用该方法了。

测试使用

最后，我们测试使用一下。为了方便，我就不用Test类去测试，直接使用Main方法去测试：

public static void main(String args[]) {
	sendMessageToWechat.sendText("Mintimate's Blogn" +
                "只为与你分享~??n" +
                "=> Bilibili：https://space.bilibili.com/355567627n"+
	"=> 腾讯云社区：https://cloud.tencent.com/developer/user/7704194n"+
                "=====n"+
                "查看更多");
}
测试代码

运行，即可以看到微信收到通知了：

微信上收到消息

样例代码

有些小伙伴可能想要文中的样例代码，为此我也在Github上进行了开源：

  • https://github.com/Mintimate/WeChatPushJava

完善思路

这样的推送服务是可以完善的。比如：

Redis存储Token

如果你有看企业微信开发者文档，你会发现Token的有效期是：1800秒。你可以使用Redis进行临时存储缓存。

发送图片

本文演示发送消息，但是接口是可以发送图片、语言等内容。且接受数据均为JSON，可以按本文方法实现：

图片消息
卡片消息

PHP接口

使用Java，直接集成在JavaWeb项目里，固然不错，但是如果想作为一个API接口，那么使用PHP是更好的选择，还可以使用Serverless：

  • PHP Web函数搭建推送服务，轻松推送消息至个人微信

总结

综上所述，就是让Java项目“说话”的方案了嗷。当然，肯定有更好的方法，但是推送到微信，也觉得是个好方法嗷~

文章来源于互联网:Java项目实现消息推送到团队微信，让项目“会说话”

原创文章，作者： Admin ，转载请注明出处：https://secvery.com/9067.html

发表评论

电子邮件地址不会被公开。 必填项已用*标注

记住昵称、邮箱和网址，下次评论免输入

猜你喜欢