Shulou(Shulou.com)06/02 Report--

This article shows you how to receive syslog in java. The content is concise and easy to understand. It will definitely brighten your eyes. I hope you can get something through the detailed introduction of this article.

/ * * receive syslog data and send them to kafka. Flink consumes kafka * * org.myorg.quickstart.kafka.UDPServer * * cd / etc/rsyslog.d * * systemctl restart rsyslog * [root@localhost rsyslog.d] # cat rs.conf * / *. * @ 192.168.1.2 flink 514 / *. * @ 192.168.1.2 flink 514 Compact /. * @ Public class UDPServer {public static void main (String [] args) throws Exception {/ / SendDataToKafka sendDataToKafka = new SendDataToKafka (); System.err.println ("UDPServer server"); byte [] byt = new byte [1024]; DatagramPacket dp = new DatagramPacket (byt, byt.length); DatagramSocket ds = new DatagramSocket (8175); while (true) {ds.receive (dp); System.err.println ("…") ; System.err.println ("- getOffset--" + dp.getOffset ()); System.err.println ("server"); System.err.println ("--received:" + new String (byt, 0, dp.getLength ()). Trim ()); / / sendDataToKafka.send ("topic1", "", "roi rpi this is a test data too") / / sendDataToKafka.send (TOPIC, "", new String (byt, 0, dp.getLength ()). Trim (); / FileUtils.append ("UDPServer.txt 2 /" + "UDPServer.txt", "" + new String (byt, 0, dp.getLength ()). Trim ());} the above is how to receive syslog in java. Have you learned any knowledge or skills? If you want to learn more skills or enrich your knowledge reserve, you are welcome to follow the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.