提示

由于java生态比较丰富，而且几乎所有人都有自己实现POST请求的工具类，这么就不提供SDK了。

java告警工具类demo

import com.alibaba.fastjson2.JSONObject;
import com.google.common.util.concurrent.RateLimiter;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;

/**
 * Java系统告警工具类
 */
public class SystemAlarmUtil {

	private final static RateLimiter rateLimiter = RateLimiter.create(1d);

	private SystemAlarmUtil() {
		super();
	}

	public static String sendAlarmMessage(String title, String message, String url) {
		try {
			// count 每次消耗的令牌10个, 那么每10秒才会通过一次 timeout 超时等待的时间, 等待超过1秒就拒绝发送
			if (!rateLimiter.tryAcquire(10, 1, TimeUnit.SECONDS)) {
				return null;
			}

			// 创建json对象作为requestBody
			JSONObject jsonObject = new JSONObject();
			jsonObject.put("head", title);
			jsonObject.put("body", message);
			jsonObject.put("url", url);
			// 添加请求头信息
			Map<String, String> heads = new HashMap<>();
			// 使用json发送请求，下面的是必须的
			heads.put("Content-Type", "application/json;charset=UTF-8");
			HttpResponse response = HttpRequest.post("https://www.phprm.com/services/push/trigger/4d2dac865118761a14d10d7d3afe7c35")
					.headerMap(heads, false).body(String.valueOf(jsonObject)).timeout(5 * 1000).execute();
			System.out.println("告警推送结果: "+response.body());
			return response.body();
		}
		catch (Exception exception) {

		}
		return null;
	}

	public static void main(String[] args) {
		SystemAlarmUtil.sendAlarmMessage("系统故障告警", "故障模块: 订单模块\n订单ID=xxxx\n订单金额: 100元\n故障原因: xxxx");
	}
}