摘要：上一篇，我初步整理了服務(wù)端接收日志的例子，本篇主要是對客戶端模擬操作的一個(gè)基本例子。

上一篇，我初步整理了Syslog服務(wù)端接收日志的例子，本篇主要是對客戶端模擬操作的一個(gè)基本例子。

package com.tony.util;
import java.io.*;    
import java.net.*;    
    
/**
 * UDP客戶端程序，用于對服務(wù)端發(fā)送數(shù)據(jù)，并接收服務(wù)端的回應(yīng)信息.   
 * Title: SyslogClient
 * Description: none
 * Copyright @ 2012~2015 HP

 * @author Tony
 * @createDate 2015年8月18日
 * @version v1.0
 */
public class SyslogClient {    
    private byte[] buffer = new byte[1024];    
    
    private DatagramSocket ds = null;    
    
    /**  
     * 構(gòu)造函數(shù)，創(chuàng)建UDP客戶端  
     * @throws Exception  
     */    
    public SyslogClient() throws Exception {    
        ds = new DatagramSocket();    
    }    
        
    /**  
     * 設(shè)置超時(shí)時(shí)間，該方法必須在bind方法之后使用.  
     * @param timeout 超時(shí)時(shí)間  
     * @throws Exception  
     */    
    public final void setSoTimeout(final int timeout) throws Exception {    
        ds.setSoTimeout(timeout);    
    }    
    
    /**  
     * 獲得超時(shí)時(shí)間.  
     * @return 返回超時(shí)時(shí)間  
     * @throws Exception  
     */    
    public final int getSoTimeout() throws Exception {    
        return ds.getSoTimeout();    
    }    
    
    public final DatagramSocket getSocket() {    
        return ds;    
    }    
 
    /**  
     * 接收從指定的服務(wù)端發(fā)回的數(shù)據(jù).  
     * @param lhost 服務(wù)端主機(jī)  
     * @param lport 服務(wù)端端口  
     * @return 返回從指定的服務(wù)端發(fā)回的數(shù)據(jù).  
     * @throws Exception  
     */    
    public final String receive(final String lhost, final int lport)    
            throws Exception {    
        DatagramPacket dp = new DatagramPacket(buffer, buffer.length);    
        ds.receive(dp);    
        String info = new String(dp.getData(), 0, dp.getLength());    
        return info;    
    }    
    
    /**  
     * 關(guān)閉udp連接.  
     */    
    public final void close() {    
        try {    
            ds.close();    
        } catch (Exception ex) {    
            ex.printStackTrace();    
        }    
    }   
    
    /**  
     * 向指定的服務(wù)端發(fā)送數(shù)據(jù)信息.  
     * @param host 服務(wù)器主機(jī)地址  
     * @param port 服務(wù)端端口  
     * @param bytes 發(fā)送的數(shù)據(jù)信息  
     * @return 返回構(gòu)造后俄數(shù)據(jù)報(bào)  
     * @throws IOException  
     */    
    public final DatagramPacket send(final String host, final int port,    
            final byte[] bytes) throws IOException {    
        DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress    
                .getByName(host), port);    
        ds.send(dp);    
        return dp;    
    }
    
    /**  
     * 測試客戶端發(fā)包和接收回應(yīng)信息的方法.  
     * @param args  
     * @throws Exception  
     */    
    public static void main(String[] args) throws Exception {    
        SyslogClient client = new SyslogClient();   
        //這里我們在本機(jī)測試，使用本機(jī)IP即可
        String serverHost = "127.0.0.1";    
        int serverPort = 514;    
        client.send(serverHost, serverPort, ("什么都可以的接收參數(shù)").getBytes());   
        String info = client.receive(serverHost, serverPort);    
        System.out.println("服務(wù)端回應(yīng)數(shù)據(jù)：" + info);
    }    
}