dsappreceiver.java

采用JAVA开发

package com.gctech.sms.app;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.log4j.Logger;

import com.gctech.util.Tools;
import com.gctech.util.net.SocketService;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class DSAppReceiver extends SocketService {
  public DSAppReceiver() {

  }
  public void run(){
    try {

      InputStream in = sock.getInputStream();
      //收到消息头
      byte[] head = new byte[16];
      in.read(head);
      int length = Tools.byte2int(head);
      length -= 16;
      if ( length <= 0 || length > 2048 )
        throw new IOException("长度不正确："+length);
      //读取消息
      System.out.println("data Length:"+length);
      byte[] data = new byte[length];
      int actual = in.read(data);
      System.out.println(new String(data));
      System.out.println(actual);
      //读取消息类型
      int cmdType = Tools.byte2int(head, 4);
      Object objService = DSAppServiceStarter.appServices.get(new Integer(cmdType));
      if ( objService == null )
        logger.warn("消息类型："+cmdType+"没有被发现！");
      else{
        SubService service = (SubService)objService;
        byte[] resp = service.service(head, data);
        OutputStream out = sock.getOutputStream();
        out.write(resp);
      }
    }
    catch (Throwable ex) {
      logger.error(ex, ex);
    }finally{
      if ( sock != null ){
        try {
          sock.close();
        }
        catch (Throwable ex1) {
          logger.error(ex1, ex1);
        }
      }
    }
  }


  static final Logger logger = Logger.getLogger(DSAppReceiver.class);

}