moserversessionlistener.java

中国联通短信通信协议

package com.wireless.sms.gwif.test.receive;

//import java.io.*;
//import java.nio.*;
//import java.nio.channels.*;
//import java.util.*;
import javax.swing.JTextArea;
//import java.beans.IntrospectionException;
import net.gleamynode.netty2.Message;
import net.gleamynode.netty2.Session;
//import net.gleamynode.netty2.SessionListener;
//import net.gleamynode.netty2.SessionLog;

//import org.apache.log4j.Logger;
//import org.xml.sax.SAXException;
//import com.wireless.sms.pub.entity.MO;
//import com.wireless.sms.pub.util.CryptoTool;
//import com.wireless.sms.pub.net.*;
//import com.wireless.sms.pub.net.CenterGlobalInterface;

import com.wireless.gwif.socketconn.*;

/**
 *
 * <p>Title: 客户端模板</p>
 * <p>Description: 与运营商连接模板，所有客户端连接实体都由此扩展</p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: Entel</p>
 * @author 刘凯
 * @version 1.0
 */
public class MOServerSessionListener extends ServerDefaultConnTemplet{

    private JTextArea txt = null;

    public MOServerSessionListener(){
    }

    public void setTextArea(JTextArea txt){
        this.txt = txt;
    }

    public void connectionEstablished(Session session) {
        txt.setText(txt.getText() + "--- Connection established : " + session.getSocketAddress() + " ---");
    }

    public void messageReceived(Session session, Message message) {

        FixedByteMessage fixedByteMessage = (FixedByteMessage)message;

        if( fixedByteMessage.getMsgType() == Constant.ACTIVEMSGREQ ){
          txt.setText(txt.getText() + "\n--- Receive ActiveTest : " + session.getSocketAddress() + " ---");

          FixedByteMessage fbm = new FixedByteMessage();
          fbm.setValue(Constant.CONNRSPMSG.getBytes());
          session.write(fbm);
        }
        else{
          txt.setText(txt.getText() + "\n--- Receive Message : " + session.getSocketAddress() + " ---\n" + new String(fixedByteMessage.getValue()));

          //对信息进行处理
          process(fixedByteMessage.getValue());
          FixedByteMessage fbm = new FixedByteMessage();
          fbm.setValue(Constant.RESPONSE.getBytes());
          session.write(fbm);
        }
    }

    public byte [] process(byte[] bytes) {
        return new byte[0];
    }

    public void processException(Throwable cause){
    }
}