package com.mm.util;

import org.graylog2.syslog4j.Syslog;
import org.graylog2.syslog4j.SyslogIF;

import java.net.URLDecoder;

/**
 * @author clown
 * * @date 2023/12/17
 */
public class SyslogClient {

    private static final String message="charset=utf-8 logType=通知 instanceName=实例1 taskName=任务2" +
            " logLevel=告警 objectName=对象1 desc=明细1 result=成功 date=2023-10-30 00:21:00";



    public static void main(String[] args) {
        send(null,0);
    }

    public static void send(String ip,Integer port){
        try {

            // 获取syslog的操作类，使用udp协议。syslog支持"udp", "tcp"协议
            SyslogIF syslog = Syslog.getInstance("udp");
            // 设置syslog服务器端地址和端口
            syslog.getConfig().setHost(ip);
            syslog.getConfig().setPort(port);
            //发送信息到服务器，2表示日志级别 范围为0~7的数字编码，表示了事件的严重程度。0最高，7最低
            syslog.log(0, URLDecoder.decode(message, "utf-8"));
            System.out.println("发送成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static Boolean sendClient(String ip,Integer port,String messageClient){
        try {
            System.out.println(messageClient);
            // 获取syslog的操作类，使用udp协议。syslog支持"udp", "tcp"协议
            SyslogIF syslog = Syslog.getInstance("tcp");
            // 设置syslog服务器端地址和端口
            syslog.getConfig().setHost(ip);
            syslog.getConfig().setPort(port);
            //发送信息到服务器，2表示日志级别 范围为0~7的数字编码，表示了事件的严重程度。0最高，7最低
            syslog.log(0, URLDecoder.decode(messageClient, "utf-8"));
            System.out.println("发送成功");
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }
}