clienthandler.java

短信发送

/**
 * Created at Nov 21, 2008
 */
package com.jdev.net;

import com.jdev.net.connector.Connection;
import com.jdev.net.connector.ConnectionFactory;
import com.jdev.net.event.EventAdapter;
import com.jdev.net.queue.Request;
import com.jdev.net.queue.Response;
import com.jdev.net.samples.NIOClient;
import com.jdev.util.Debug;

/**
 * <p>Title: ClientHandler</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 1.0
 */
public class ClientHandler extends EventAdapter {

	private ConnectionFactory connFactory = ConnectionFactory
			.getInstance(ConnectionFactory.CLIENT);

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onClosed(com.jdev.net.queue.Request)
	 */
	@Override
	public void onClosed(Request request) throws Exception {
		// TODO Auto-generated method stub
		super.onClosed(request);
		Connection conn = connFactory.getConnection();
		conn.open("127.0.0.1", 6188);
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onConnected()
	 */
	@Override
	public void onConnected() throws Exception {
		// TODO Auto-generated method stub
		super.onConnected();
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onError(java.lang.String)
	 */
	@Override
	public void onError(String error) {
		// TODO Auto-generated method stub
		super.onError(error);
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onRead(com.jdev.net.queue.Request)
	 */
	@Override
	public void onRead(Request request) throws Exception {
		// TODO Auto-generated method stub
		super.onRead(request);
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onWrite(com.jdev.net.queue.Request, com.jdev.net.queue.Response)
	 */
	@Override
	public void onWrite(Request request, Response response) throws Exception {
		// TODO Auto-generated method stub
		super.onWrite(request, response);
	}

	/**
	 * 
	 */
	public ClientHandler() {
		// TODO Auto-generated constructor stub
	}

	public void Start() {
		try {
			Connection conn = connFactory.getConnection();
			conn.open("127.0.0.1", 6188);

			conn.writeString("test ok");
			String str = conn.readString();

			Debug.logVerbose(str);

		} catch (Exception e) {

		}
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			//          ServerHandler server = new ServerHandler();
			//          Notifier notifier = Notifier.getNotifier();
			//          notifier.addListener(server);
			//
			//          System.out.println("Server starting ...");
			//          Reactor s = new Reactor(6188);
			//          Thread tServer = new Thread(s);
			//          tServer.start();
			ClientHandler server = new ClientHandler();
			server.Start();

		} catch (Exception e) {
			System.out.println("Server error: " + e.getMessage());
			System.exit(-1);
		}
	}

}