`
macken
  • 浏览: 346062 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

logback udp appender

    博客分类:
  • Java
 
阅读更多

package com.macken;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

import ch.qos.logback.classic.encoder.PatternLayoutEncoder;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.core.AppenderBase;

public class UpdAppender extends AppenderBase<ILoggingEvent> {

	PatternLayoutEncoder encoder;
	int port;
	String ip;
	DatagramSocket socket;


	public PatternLayoutEncoder getEncoder() {
		return encoder;
	}
	public void setEncoder(PatternLayoutEncoder encoder) {
		this.encoder = encoder;
	}
	public int getPort() {
		return port;
	}
	public void setPort(int port) {
		this.port = port;
	}
	public String getIp() {
		return ip;
	}
	public void setIp(String ip) {
		this.ip = ip;
	}

	public DatagramSocket getSocket() {
		return socket;
	}
	public void setSocket(DatagramSocket socket) {
		this.socket = socket;
	}
	public UpdAppender() {
//		this.ip="10.11.199.154";
//		this.port=5070;
	}
	@Override
	public void start() {
		if (this.encoder == null) {
			addError("no layout of udp appender");
			return;
		}
		if (socket==null) {
			try {
				socket = new DatagramSocket(port);
			} catch (SocketException e) {
				e.printStackTrace();
			} 
		}
		super.start();
	}
	@Override
	protected void append(ILoggingEvent event) {
		byte[] buf = encoder.getLayout().doLayout(event).trim().getBytes();
		try {
			InetAddress address = InetAddress.getByName(ip);
			DatagramPacket p = new DatagramPacket(buf, buf.length, address, port);
			socket.send(p);
		} catch (Exception e) {
			e.printStackTrace();
		}

	}
	@Override
	public void stop() {
		if (!socket.isClosed()) {
			socket.close();
		}
		super.stop();
	}

}

 配置文件:

<configuration>
	<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
		<encoder>
			<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
		</encoder>
	</appender>
	<appender name="upd" class="com.macken.UpdAppender">
		<encoder>
			<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
		</encoder>
		<ip>10.11.199.154</ip>
		<port>5070</port>
	</appender>
	<root level="debug">
		<!--  <appender-ref ref="STDOUT" />-->
		<appender-ref ref="upd" />
	</root>
</configuration>
 
分享到:
评论

相关推荐

    logback-gelf-appender:发送GELF消息的Logback追加程序

    GELF Appender登录 此回退附加程序将消息记录到Graylog服务器。 它使用官方的连接到远程服务器。 它受到的启发和影响。 附加程序具有几个可配置的属性: server (默认值: localhost ) GELF服务器的主机名或IP地址...

    LogBack日志的使用

    LogBack支持将日志发送到远程服务器,如通过TCP、UDP或HTTP。这需要配置`SocketAppender`或`HTTPAppender`,并指定接收日志的服务端地址和端口。 总的来说,LogBack提供了一套强大的日志解决方案,包括灵活的配置、...

    gelfback:另一个GELF附加程序,用于登录

    另一个用于 logback 的 GELF appender 这是一个用于 logback 的 GELF appender,重点略有不同。 具体来说: 通过 TCP 发送消息,但不要使用网络 IO 阻塞日志记录路径(因为我们在 Graylog 前面使用了 AWS ELB,...

    scala通过logstash发送日志到kafka的Demo

    例如,你可以创建一个UDP或TCP appender,指定`host`为Logstash服务器的IP地址和`port`为Logstash配置中的输出端口。 ```xml &lt;appender name="LOGSTASH" class=...

    springboot接入elk1

    例如,如果你使用Logback,可以在`logback-spring.xml`配置文件中设置一个UDP Appender,将日志发送到Logstash的UDP端口: ```xml &lt;appender name="UDP" class="ch.qos.logback.core.rolling.RollingFileAppender...

    MetaModel-dbase-3.4.8.zip

    - **Logback集成**:配置Logback的appender,添加GelfAppender,设置相关参数。 - **命令行接口**:gelf4j还提供了命令行工具,可以直接发送GELF消息,无需依赖任何日志框架。 4. **gelf4j-master中的内容** - *...

    java发送syslog日志,支持多目的ip

    &lt;appender name="SYSLOG" class="ch.qos.logback.ext.syslog.SyslogAppender"&gt; &lt;syslogHost&gt;localhost &lt;facility&gt;LOCAL0 &lt;port&gt;514 &lt;/appender&gt; &lt;appender-ref ref="SYSLOG" /&gt; ``` 3. **多目的地IP支持*...

    syslog-server.zip

    3. 创建Logback配置文件:在项目资源目录下创建`logback-syslog.xml`或`logback-syslog.yml`,配置Syslog Appender,指定日志接收方式(UDP或TCP)和目标地址: ```xml &lt;appender name="SYSLOG" class="org.gray...

    Graylog基础使用

    这通常涉及到对Logback Appender的配置调整。 4. **Maven配置** 如果使用Maven构建项目,还需要在`pom.xml`中配置相关插件以支持日志输出至Graylog。 #### 四、使用与监控 - **访问Web界面**: Graylog提供了一...

    mina2.0.7-jar包

    SLF4J(Simple Logging Facade for Java)是Java的日志门面,它为各种日志框架提供了一个统一的接口,如Log4j、java.util.logging、Logback等。在描述中提到,SLF4J也是这个压缩包的一部分,这表明MINA项目依赖于SLF...

Global site tag (gtag.js) - Google Analytics