iserverhandler.java

同步接收web services请求

package com.aceway.vas.commons.tcp;

import java.io.Serializable;
import java.nio.channels.SocketChannel;

import com.aceway.vas.commons.tcp.impl.ConnectInfo;

public interface IServerHandler {

	//当有新连接时响应
	public void onConnect(int connectId, String ip, int port );

	//当新连接断开的时候,响应
	public void onDisconnect(int connectId, Object attachObj);

	/*
	 * 服务器端应用程序对接收到的消息进行切片
	 * 如果可以切到一个完整的消息包,就返回此包的长度,
	 * 如果没有得到一个完整的消息包,就返回-1.
	*/
	public int slice(int connectId, byte[] bytes);

	public void onReceiveMsg(int connectId, Object attachObj, byte[] bytes);

	public void onReceiveMsg(int connectId, Object attachObj, Serializable obj);

	void onSendedMsg(int connectId, Object attachObj, byte[] bytes);

	void onSendedMsg(int connectId, Object attachObj, Serializable obj);

}