3.5.3 Socket Adapter

Sample program source code:

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
 
public class SocketClient {
    Socket s = new Socket();
    
    public static void main(String[] args) {
        String hostName = "";
        int    port = 0;
        String dataType = "";
        String charSet = "";
        String eventTypeId = "";
        String data = "";
        long   lWait = 10;
        int    loop = 0;
        int    dataCount = 1;
        
        if (args.length != 9) {
            System.out.println("param is Abnormal");
            return;
        }
        
        try {
            hostName    = String.valueOf(args[0]);
            port        = Integer.valueOf(args[1]);
            dataType    = String.valueOf(args[2]);
            charSet     = String.valueOf(args[3]);
            eventTypeId = String.valueOf(args[4]);
            data        = String.valueOf(args[5]);
            lWait       = Long.valueOf(args[6]);
            loop        = Integer.valueOf(args[7]);
            dataCount   = Integer.valueOf(args[8]);
            
            SocketClient c = new SocketClient(hostName, port);
            c.sendMessage(dataCount, dataType, charSet, eventTypeId, data, loop, lWait);
            
            System.out.println(c.readResponse());
            
        } catch (InterruptedException e) {
            e.printStackTrace();
            return;
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }
    }
    
    public void sendMessage(int dataCount, String dataType, String charSet, 
        String eventTypeId,String data, int loop, long wait) 
        throws IOException, InterruptedException {
        
        DataOutputStream dos = new DataOutputStream(
                new BufferedOutputStream(s.getOutputStream()));
        
        for (int k = 0; k < loop; k++) {
            
            for (int i = 0; i < dataCount; i++) {
                int count = ( k * dataCount ) + i;
                String msg = data.replaceAll("%COUNTER%", String.valueOf(count));
                
                int length = dataType.getBytes().length + 4 + eventTypeId.getBytes().length
                 + 4 + charSet.getBytes().length + 4 + msg.getBytes().length;
                dos.writeInt(length);
                
                dos.write(dataType.getBytes());
                
                dos.writeInt(eventTypeId.getBytes().length);
                dos.write(eventTypeId.getBytes());
                
                dos.writeInt(charSet.getBytes().length);
                dos.write(charSet.getBytes());
                
                dos.writeInt(msg.getBytes().length);
                dos.write(msg.getBytes(charSet));
                
                dos.flush();
            }
            
            Thread.sleep(wait);
        }
        dos.writeInt(0);
        dos.flush();
    }
    
    public SocketClient(String host, int port) throws IOException {
        InetSocketAddress address = new InetSocketAddress(InetAddress.getByName(host),
            Integer.valueOf(port));
        s.setSendBufferSize(1000000000);
        s.connect(address);
    }
    
    public String readResponse() throws IOException {
        BufferedReader br = new BufferedReader( new InputStreamReader(s.getInputStream()));
        
        String ret =br.readLine();
        System.out.println("RESPONSE:" + ret);
        return "";
    }
}

The following data are obtained from the arguments at runtime:

Argument	Variable	Use
1	hostName	CEP Server host name
2	port	Socket adapter port
3	dataType	Event data format
4	charSet	Character set
5	eventTypeId	Event type ID
6	data	Event data %COUNTER% included in event data needs to be substituted with loop count so that different event data shall be sent at each loop.
7	lWait	Data transmission wait time
8	loop	Data transmission count
9	dataCount	Number of event data to send at a time

3.5.3.1 Example of Sample Execution(Sends a CSV data)

An example of sample execution is shown below.

In this example, debug information is output to the engine log by using DebugLogListener.

Command execution result

# java -cp ./ SocketClient localhost 8001 CSV UTF-8 CSVEvent SOCKET,CSV,%COUNTER% 1 2 2 <ENTER>
RESPONSE:0000:6:Sending message completed normally.

Engine log output result

2012-07-29 13:27:49,410 [DEBUG] abc:length=1
abc[0]
        operation       :CSV: String
        count   :0: String
        ID      :SOCKET: String

2012-07-29 13:27:49,422 [DEBUG] abc:length=1
abc[0]
        operation       :CSV: String
        count   :1: String
        ID      :SOCKET: String

2012-07-29 13:27:49,427 [DEBUG] abc:length=1
abc[0]
        operation       :CSV: String
        count   :2: String
        ID      :SOCKET: String

2012-07-29 13:27:49,428 [DEBUG] abc:length=1
abc[0]
        operation       :CSV: String
        count   :3: String
        ID      :SOCKET: String

3.5.3.2 Example of Sample Execution(Sends an XML data)

An example of sample execution is shown below.

In this example, debug information is output to the engine log by using DebugLogListener.

Command execution result

# java -cp ./ SocketClient localhost 8001 XML UTF-8 XMLEvent '<?xml version="1.0"\
 encoding="UTF-8"?><XMLEvent><ID>SOCKET</ID> <operation>XML</operation>\
 <count>%COUNTER%</count></XMLEvent>' 1 2 2 <ENTER>
RESPONSE:0000:4:Sending message completed normally.

Please note that we added backslash ("\") and newline characters in the command line example above for readability only - the actual command line does not have a backslash and newline.

Engine log output result

2012-07-29 13:30:56,861 [DEBUG] abc--0:length=1
abc--0[0]
        operation       :XML: String
        count   :0: String
        ID      :SOCKET: String
 
2012-07-29 13:30:56,862 [DEBUG] abc--0:length=1
abc--0[0]
        operation       :XML: String
        count   :1: String
        ID      :SOCKET: String
 
2012-07-29 13:30:56,865 [DEBUG] abc--0:length=1
abc--0[0]
        operation       :XML: String
        count   :2: String
        ID      :SOCKET: String
 
2012-07-29 13:30:56,865 [DEBUG] abc--0:length=1
abc--0[0]
        operation       :XML: String
        count   :3: String
        ID      :SOCKET: String