前段时间写了个web端与C服务端之间的通信不过用的是短连接 非堵塞的方式，一直想使用长连接，使tomcat启动的时候就和C服务端进行通信，但是一直没找到方法希望je的朋友能给点思路。先来看我现在的具体实现
通信的核心类
public class newsSockBase
{
private SocketChannel sc;
private final int MAX_LENGTH = 8192 ;
private ByteBuffer r_buff ;
private ByteBuffer w_buff ;
private static String host ;
private static int port;
int sendBufTotalLen;
int sendBufLen;
int sendBufStart;
byte [] sendBuf;
int recvBufTotalLen;
int recvBufLen;
int recvBufStart;
byte [] recvBuf;
int timeout;
String msg;
public newsSockBase()
{
r_buff = ByteBuffer.allocate(MAX_LENGTH);
w_buff = ByteBuffer.allocate(MAX_LENGTH);
sendBufTotalLen = MAX_LENGTH;
sendBufLen = sendBufStart = 0 ;
sendBuf = new byte [MAX_LENGTH];
recvBufTotalLen = MAX_LENGTH;
recvBufLen = recvBufStart = 0 ;
recvBuf = new byte [MAX_LENGTH];
timeout = 6 ;
}
public void setIPandPort(String str, int pt)
{
host = str;
port = pt;
}
//这两个函数一定要注意 形参是基类 而实际传入的参数是子类，到时候也是调用子类的参数来做
public void getBufFrompara(InewsDetail nD)
{
int len = nD.encode(sendBuf, sendBufStart, sendBufTotalLen-sendBufStart-sendBufLen);
sendBufLen += len;
}
public int decodeBufToPara(InewsDetail nD)
{
int len = nD.decode(recvBuf, recvBufStart, recvBufLen);
if (len> 0 ) //解码正确的时候才做
{
recvBufLen -= len;
recvBufStart += len;
}
return len;
}
public void start(InewsDetail nD)
{
//这里需要先根据传入的参数来
getBufFrompara(nD);
try {
InetSocketAddress addr = new InetSocketAddress(host, port);
// 生成一个socketchannel
sc = SocketChannel.open();
sc.configureBlocking( false ); //
// 连接到server
sc.connect(addr);
while (!sc.finishConnect())
;
System.out.println( "connection has been established!…" );
// while (true)
{
// 回射消息 // 复位，清空
w_buff.clear();
w_buff.put(sendBuf,sendBufStart,sendBufLen);
w_buff.flip(); // 转到最开始
// 发送消息
while (w_buff.hasRemaining())
sc.write(w_buff);
w_buff.clear();
// 进入接收状态
while ( true )
{
int ss= 0 ;
int count;
r_buff.clear();
while (ss<timeout* 100 )
{
count = sc.read(r_buff);
if (count> 0 )
break ;
ss++;
Thread.currentThread().sleep( 10 );
}
if (ss==timeout)
{
break ;
}
r_buff.flip();
//判断recvBuf能不能放下接收到的数据
if (r_buff.limit()+recvBufStart+recvBufLen>recvBufTotalLen)
{
//放不下了
//那就先看看前面是不是有空余
if (recvBufStart> 0 )
{
for ( int i= 0 ;i<recvBufStart;i++)
{
recvBuf = recvBuf[i+recvBufStart]; } recvBufStart = 0; } if (r_buff.limit()+recvBufStart+recvBufLen>recvBufTotalLen) { //这个时候就是真的说数据区长度不够了，属于致命错误 System.err.println("致命错误！ 缓冲区长度过小！"); } } else { // 也可以转化为字符串，不过需要借助第三个变量了。 r_buff.get(recvBuf,recvBufStart+recvBufLen,r_buff.limit()); //得到了一次数据就要试着做一次解码，如果能够解码，那就完成解码，不能则表示数据不完整，继续等待新数据 //这里注意返回值 如果是0 表示数据不完整 如果是正数 就是解码的字节数 负数表示解码出错 recvBufLen += r_buff.limit(); if (decodeBufToPara(nD)!=0) break; } System.out.println("reply is " + r_buff.limit() + " long " ); } } sc.socket().close(); } catch (IOException ioe) { ioe.printStackTrace(); } catch (InterruptedException ie) { ie.printStackTrace(); } System.out.println("Exit App....... " ); } public static void main(String[] args) { newsDetailNewsSum nDNS = new newsDetailNewsSum(); newsSockBase nsb = new newsSockBase(); nsb.setIPandPort("192.168.0.106",8888); nsb.start(nDNS); System.out.println("Exit Allllll....... " ); } } 下面是报文协议的基类//此类试图将所有的通讯协议的编解码都包含在内！按照一次交互的过程来区分 public class newsDetail implements InewsDetail { protected int netErr; //用来表示是不是网络出错了，主要是超时。这个时候就不需要检查其他参数了。 protected int type; //就是对应具体的操作类型码 protected byte[] StreamID=new byte[16]; //对应具体的流水号 protected byte[] asyn = new byte[2]; //这个还是有问题 不能达到预计效果 需要修改 static private int seq=0; //生成流水号后2位的时候使用的 static private Calendar lastCa; public newsDetail() { getStreamID(); } public int getType() { return type; } public void setType(int type) { this.type = type; } //基类中的编解码函数没有作用，具体使用的编解码函数在各个子类中需要重新实现 //必须有返回值 因为调用者需要根据返回值做一些操作 //这里的参数 buf是需要填写的缓冲区 start 是缓冲区开始位置 len 是可用的缓冲区长度 public int encode(byte[] buf,int start,int len) { return 0; } //这里的参数 buf是需要需要解码的缓冲区 start 是缓冲区开始位置 len 是需要解码的长度 public int decode(byte[] buf,int start,int len) { return 0; } public void getStreamID() { Calendar ca = Calendar.getInstance(); int year = ca.get(Calendar.YEAR);//获取年份 int month=ca.get(Calendar.MONTH)+1;//获取月份 int day=ca.get(Calendar.DATE);//获取日 int minute=ca.get(Calendar.MINUTE);//分 int hour=ca.get(Calendar.HOUR);//小时 int second=ca.get(Calendar.SECOND);//秒 int am_pm=ca.get(Calendar.AM_PM); if (am_pm==Calendar.PM) hour += 12; if (hour>=24) hour -= 24; System.out.println(seq); if (lastCa!=ca) { lastCa = ca; seq = 12; } else { seq++; if (seq>=100) seq = 0; } //现在根据上面的字段组成StreamID字符串 //目前先使用手工的办法来写，效率高一些 StreamID[0] = (byte)(year/1000+'0'); StreamID[1] = (byte)((year-(StreamID[0]-'0')*1000)/100+'0'); StreamID[2] = (byte)((year-(StreamID[0]-'0')*1000-(StreamID[1]-'0')*100)/10+'0'); StreamID[3] = (byte)(year-(StreamID[0]-'0')*1000-(StreamID[1]-'0')*100-(StreamID[2]-'0')*10+'0'); StreamID[4] = (byte)(month/10+'0'); StreamID[5] = (byte)((month-(StreamID[4]-'0')*10)+'0'); StreamID[6] = (byte)(day/10+'0'); StreamID[7] = (byte)((day-(StreamID[6]-'0')*10)+'0'); StreamID[8] = (byte)(hour/10+'0'); StreamID[9] = (byte)((hour-(StreamID[8]-'0')*10)+'0'); StreamID[10] = (byte)(minute/10+'0'); StreamID[11] = (byte)((minute-(StreamID[10]-'0')*10)+'0'); StreamID[12] = (byte)(second/10+'0'); StreamID[13] = (byte)((second-(StreamID[12]-'0')*10)+'0'); StreamID[14] = (byte)(seq/10+'0'); StreamID[15] = (byte)((seq-(StreamID[14]-'0')*10)+'0'); System.out.println("现在时间"); System.out.println("用Calendar.getInstance().getTime()方式显示时间: " + ca.getTime()); System.out.println("用Calendar获得日期是：" + year +"年"+ month +"月"+ day + "日"); System.out.println("用Calendar获得时间是：" + hour +"时"+ minute +"分"+ second +"秒"); } public static void main(String[] args) { { newsDetail nn1 = new newsDetail(); } try { Thread.currentThread().sleep(3000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }