首次提交

Lius

2025-02-27 f06f695488a64dcc0945e282dffe120148f21dca

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
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;
        }
    }
}