smppconnection.java

华为CNGP.CMPP.SGIP.CMPP源代码。

package com.huawei.insa2.comm.smpp;

import com.huawei.insa2.comm.*;
import com.huawei.insa2.comm.smpp.message.SMPPEnquireLinkMessage;
import com.huawei.insa2.comm.smpp.message.SMPPEnquireLinkRespMessage;
import com.huawei.insa2.comm.smpp.message.SMPPLoginMessage;
import com.huawei.insa2.comm.smpp.message.SMPPLoginRespMessage;
import com.huawei.insa2.comm.smpp.message.SMPPMessage;
import com.huawei.insa2.comm.smpp.message.SMPPUnbindMessage;
import com.huawei.insa2.util.Args;
import com.huawei.insa2.util.Resource;
import java.io.*;

public class SMPPConnection extends PSocketConnection {

	private int degree;

	private int hbnoResponseOut;

	private String systemId;

	private String password;

	private String systemType;

	private byte interfaceVersion;

	private byte addrTon;

	private byte addrNpi;

	private String addressRange;

	public SMPPConnection(Args args) {
		degree = 0;
		hbnoResponseOut = 3;
		systemId = args.get("system-id", "");
		password = args.get("password", "");
		systemType = args.get("system-type", "");
		interfaceVersion = (byte) args.get("interface-version", 34);
		addrTon = (byte) args.get("addr-ton", 0);
		addrNpi = (byte) args.get("addr-npi", 0);
		addressRange = args.get("address-range", "");
		SMPPConstant.debug = args.get("debug", false);
		SMPPConstant.initConstant(getResource());
		init(args);
	}

	protected PWriter getWriter(OutputStream out) {
		return new SMPPWriter(out);
	}

	protected PReader getReader(InputStream in) {
		return new SMPPReader(in);
	}

	public int getChildId(PMessage message) {
		SMPPMessage mes = (SMPPMessage) message;
		int sequenceId = mes.getSequenceId();
		if (mes.getCommandId() == 5 || mes.getCommandId() == 21
				|| mes.getCommandId() == 6)
			return -1;
		else
			return sequenceId;
	}

	public PLayer createChild() {
		return new SMPPTransaction(this);
	}

	public int getTransactionTimeout() {
		return super.transactionTimeout;
	}

	public Resource getResource() {
		try {
			Resource resource = new Resource(getClass(), "resource");
			return resource;
		} catch (IOException e) {
			e.printStackTrace();
		}
		Resource resource1 = null;
		return resource1;
	}

	public synchronized void waitAvailable() {
		try {
			if (getError() == PSocketConnection.NOT_INIT)
				wait(super.transactionTimeout);
		} catch (InterruptedException interruptedexception) {
		}
	}

	public void close() {
		try {
			SMPPUnbindMessage msg = new SMPPUnbindMessage();
			send(msg);
		} catch (PException pexception) {
		}
		super.close();
	}

	protected void heartbeat() throws IOException {
		SMPPTransaction t = (SMPPTransaction) createChild();
		SMPPEnquireLinkMessage hbmes = new SMPPEnquireLinkMessage();
		t.send(hbmes);
		t.waitResponse();
		SMPPEnquireLinkRespMessage rsp = (SMPPEnquireLinkRespMessage) t
				.getResponse();
		if (rsp == null) {
			degree++;
			if (degree == hbnoResponseOut) {
				degree = 0;
				throw new IOException(SMPPConstant.HEARTBEAT_ABNORMITY);
			}
		} else {
			degree = 0;
		}
		t.close();
	}

	protected synchronized void connect() {
		super.connect();
		if (!available())
			return;
		SMPPLoginMessage request = null;
		SMPPLoginRespMessage rsp = null;
		try {
			request = new SMPPLoginMessage(1, systemId, password, systemType,
					interfaceVersion, addrTon, addrNpi, addressRange);
		} catch (IllegalArgumentException e) {
			e.printStackTrace();
			close();
			setError(SMPPConstant.CONNECT_INPUT_ERROR);
		}
		SMPPTransaction t = (SMPPTransaction) createChild();
		try {
			t.send(request);
			PMessage m = super.in.read();
			onReceive(m);
		} catch (IOException e) {
			e.printStackTrace();
			close();
			setError(String.valueOf(SMPPConstant.LOGIN_ERROR)
					+ String.valueOf(explain(e)));
		}
		rsp = (SMPPLoginRespMessage) t.getResponse();
		if (rsp == null) {
			close();
			setError(SMPPConstant.CONNECT_TIMEOUT);
		}
		t.close();
		if (rsp != null && rsp.getStatus() != 0) {
			close();
			setError(SMPPConstant.OTHER_ERROR);
		}
		notifyAll();
	}
}