java log收集

时间：2015-05-04 16:00:02 阅读：148 评论：0 收藏：0 [点我收藏+]

标签：

java 代码：

package com.sohu.smc.web;

/**
 * Created by xuanli on 2015/4/17.
 */

import com.sohu.smc.data.utils.MyStringUtils;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
import org.eclipse.jetty.server.Request;
import org.eclipse.jetty.server.handler.AbstractHandler;
import org.slf4j.LoggerFactory;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServlet;

import org.eclipse.jetty.server.handler.AbstractHandler;
import org.eclipse.jetty.server.handler.ContextHandler;


public class SgifLogWeb {


  //  private final static org.slf4j.Logger logger = LoggerFactory.getLogger(SgifLogWeb.class);

    private final static org.slf4j.Logger logger = LoggerFactory.getLogger(SgifLogWeb.class);

    /**
     * <pre>
     * @param args
     * </pre>
     */
    final static  int port = 11229;
    public static void main(String[] args) {
        try {

            logger.info("start server port is:"+port);
            Server server = new Server(port);

            ServletContextHandler context = new ServletContextHandler(
                    ServletContextHandler.NO_SESSIONS);
            context.setContextPath("/");
            server.setHandler(context);

            context.addServlet(new ServletHolder(new SearchServlet()),
                    "/s.gif");

            server.start();
            server.join();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

class SearchServlet extends HttpServlet {
    private final static org.slf4j.Logger logger = LoggerFactory.getLogger("logmsg");

    private static final long serialVersionUID = -4012838481920999524L;




    /**
     * 写在这里的代码都是 POST 请求
     */
    @Override
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        request.setCharacterEncoding("UTF-8");
        StringBuilder buffer = new StringBuilder();
        BufferedReader reader=null;
        try{
            reader = new BufferedReader(new InputStreamReader(request.getInputStream(),"UTF-8"));
            String line=null;
            while((line = reader.readLine())!=null){

                buffer.append(line+‘\n‘);
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            if(null!=reader){
                try {
                    reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }


        String[] arrays =buffer.toString().split("\n");

        String dateString = MyStringUtils.getdatestring();

        for(String dada :arrays) {
                 logger.info(dateString+"\t"+dada);
        }

    }

    /**
     * 写在这里的代码都是 GET 请求
     */
    @Override
    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        String query = request.getParameter("query");



        String result = "welcome to my server. It‘s a GET request.";
        if (null != query && !query.trim().equals("")) {
            result = query + ", " + result;
        }

    }
}
/*
class HelloHandler extends AbstractHandler {

    private final static org.slf4j.Logger logger = LoggerFactory.getLogger("logmsg");

    @Override
    public void handle(String target, Request baseRequest,
                       HttpServletRequest request, HttpServletResponse response)
            throws IOException, ServletException {

        */
/**
         * <pre>
         * 从 URL 里面得到传递过来的参数：
         *  http://localhost:8080/search?query=hello
         * 如果你需要传递更多的参数，可以这么写：
         *  http://localhost:8080/search?query=hello&name=ZhangLili
         * 从这里开始，你可以写自己的代码逻辑。
         *
         * [注意：GET方法的请求，URL 的最大长度是 1024个字节]
         * </pre>
         *//*

        java.io.BufferedInputStream bis=new java.io.BufferedInputStream(request.getInputStream());
        byte read[] = new byte[1024*1024];
        String msg="";
        while( ( bis.read(read, 0, 1024*1024)) != -1 )
        {
            msg+=new String(read,0,1024*1024);
        }

        logger.info(msg);

     */
/*   String query = request.getParameter("query");
        // String name = request.getParameter("name");



        String result = "welcome to my server.";
        if (null != query && query.equals("hello")) {
            result = query + ", " + result;
        }


        // 将服务器处理后的结果返回给调用URL的客户端
        print(baseRequest, response, result);*//*

    }

    */
/**
     * <pre>
     * @param baseRequest
     * @param response
     * @param result 需要返回给客户的结果
     * @throws IOException
     * 将结果 result 返回给客户
     * </pre>
     *//*

    private void print(Request baseRequest, HttpServletResponse response,
                       String result) throws IOException {
        response.setContentType("text/json;charset=utf-8");
        response.setStatus(HttpServletResponse.SC_OK);
        baseRequest.setHandled(true);
        response.getWriter().println(result);
    }



}*/

logback 配置：

<?xml version="1.0" encoding="UTF-8"?>

</layout>

</appender>

</rollingPolicy>

</layout>

</appender>

<appender-ref ref="FILE" />

<appender-ref ref="STDOUT" />

</logger>

<appender-ref ref="STDOUT" />

</root>

</configuration>

maven：

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<artifactId>realtime-parent</artifactId>

<version>1.0-SNAPSHOT</version>

</parent>

<artifactId>data-platform-controler</artifactId>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<spring-version>3.1.4.RELEASE</spring-version>

<jetty-version>8.1.5.v20120716</jetty-version>

</properties>

<description>all kinds of consumers, it‘s a worker running always.</description>

<groupId>org.eclipse.jetty</groupId>

<artifactId>jetty-servlet</artifactId>

<version>${jetty-version}</version>

</dependency>

<groupId>org.eclipse.jetty</groupId>

<artifactId>jetty-webapp</artifactId>

<version>${jetty-version}</version>

</dependency>

<groupId>org.eclipse.jetty</groupId>

<artifactId>jetty-servlets</artifactId>

<version>${jetty-version}</version>

</dependency>

<groupId>javax.servlet</groupId>

</dependency>

</dependency>

<!-- <dependency>

<artifactId>realtime-core</artifactId>

<version>1.0-SNAPSHOT</version>

</dependency>-->

<artifactId>jackson-mapper-asl</artifactId>

<groupId>org.codehaus.jackson</groupId>

</dependency>

<groupId>org.codehaus.jackson</groupId>

<artifactId>jackson-core-asl</artifactId>

</dependency>

<groupId>javax.jdo</groupId>

</dependency>

<groupId>javax.xml</groupId>

</dependency>

</dependency>

<artifactId>3part-commons-io</artifactId>

</dependency>

<artifactId>3part-commons-codec</artifactId>

</dependency>

<artifactId>smc-flume</artifactId>

</dependency>

<groupId>org.xerial.snappy</groupId>

<artifactId>snappy-java</artifactId>

<version>1.1.0-SNAPSHOT</version>

</dependency>

<artifactId>smc-common-nsq</artifactId>

<version>1.5-SNAPSHOT</version>

</dependency>

<artifactId>smc-common-nsq-factory</artifactId>

<version>1.5-SNAPSHOT</version>

</dependency>

<artifactId>smc-common-kafka8</artifactId>

<version>1.5-SNAPSHOT</version>

<groupId>ch.qos.logback</groupId>

<artifactId>logback-classic</artifactId>

</exclusion>

</exclusion>

</exclusion>

</exclusions>

</dependency>

<!-- 使用该模块中封装的Kafka生产者接口

<artifactId>smc-common-kafka</artifactId>

<version>1.6-SNAPSHOT</version>

<groupId>ch.qos.logback</groupId>

<artifactId>logback-classic</artifactId>

</exclusion>

</exclusion>

</exclusion>

</exclusions>

</dependency>

-->

<groupId>org.apache.httpcomponents</groupId>

<artifactId>httpclient</artifactId>

</dependency>

<groupId>org.fusesource.leveldbjni</groupId>

<artifactId>leveldbjni-all</artifactId>

</dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

</dependency>

<artifactId>smc-common-metrics</artifactId>

<version>1.5-SNAPSHOT</version>

</dependency>

<artifactId>smc-common-scribe</artifactId>

<version>1.5-SNAPSHOT</version>

</exclusion>

</exclusions>

</dependency>

<!-- <dependency>

<artifactId>realtime-userinfo</artifactId>

<version>1.2-SNAPSHOT</version>

</dependency>-->

<groupId>org.tarantool</groupId>

<artifactId>smc-tarantool-connector</artifactId>

</dependency>

</dependencies>

<build>

<directory>${basedir}/src/main/resources</directory>

<include>**/*.properties</include>

</includes>

</resource>

<directory>${basedir}/src/main/java</directory>

<exclude>**/*.class</exclude>

</excludes>

</resource>

</resources>

<artifactId>maven-assembly-plugin</artifactId>

<descriptor>distribution.xml</descriptor>

</descriptors>

</configuration>

<id>make-assembly</id>

<phase>package</phase>

<goals>

<goal>single</goal>

</goals>

</execution>

</executions>

</plugin>

</plugins>

</pluginManagement>

</build>

<id>online</id>

<name>profile</name>

<value>online</value>

</property>

</activation>

<profile.active>online</profile.active>

</properties>

<build>

<artifactId>maven-assembly-plugin</artifactId>

</plugin>

</plugins>

</build>

</profile>

<id>develop</id>

<profile.active>develop</profile.active>

</properties>

<build>

<artifactId>maven-assembly-plugin</artifactId>

</plugin>

</plugins>

</build>

</profile>

<profile.active>test</profile.active>

</properties>

<build>

<artifactId>maven-assembly-plugin</artifactId>

</plugin>

</plugins>

</build>

</profile>

</profiles>

</project>

java log收集

标签：

原文地址：http://my.oschina.net/u/1388024/blog/410411

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行