package org.jeecg.modules.dnc.utils;
|
|
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 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;
|
}
|
}
|
}
|
