Java Develop

Development Platform:
Java

Deliver.java：Code Content
							package com.zzxy.shortmessage.SGIP;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.channels.SocketChannel;
public class Deliver extends SGIPAbstractStruct {
	public String Mobile_no; // 21B 发送短消息的用户手机号，手机号码前加"86"国别标志
	public String SPNumber; // 21B SP的接入号码
	public byte TP_pid; // 1B GSM协议类型。详细解释请参考GSM03.40中的9.2.3.9
	public byte TP_udhi; // 1B GSM协议类型。详细解释请参考GSM03.40中的9.2.3.23,仅使用1位，右对齐
	public byte MessageCoding; // 1B
								// 短消息的编码格式。0：纯ASCII字符串3：写卡操作4：二进制编码8：UCS2编码15:
								// GBK编码其它参见GSM3.38第4节：SMS Data Coding Scheme
	public int MessageLength;// 4B Integer 短消息的长度
	public String msg;// Message Length 短消息的内容
	public String Reserve;// 8B 保留，扩展用
	public static final int STRUCT_SIZE = 49;// 不含短消息内容的长度
	// @Override
	public ByteBuffer getBuffer() {
		ByteBuffer buffer = ByteBuffer.allocate(STRUCT_SIZE + MessageLength);
		buffer.order(byteOrder);
		buffer.put(Mobile_no.getBytes());
		for (int i = Mobile_no.getBytes().length; i < 21; i++) {
			buffer.put((byte) 0);
		}
		buffer.put(SPNumber.getBytes());
		for (int i = SPNumber.getBytes().length; i < 21; i++) {
			buffer.put((byte) 0);
		}
		buffer.put(TP_pid);
		buffer.put(TP_udhi);
		buffer.put(MessageCoding);
		buffer.putInt(MessageLength);
		buffer.put(msg.getBytes());
		for (int i = 0; i < 8; i++) {
			buffer.put((byte) 0);
		}
		buffer.flip();
		return buffer;
	}
	// @Override
	public void setBuffer(ByteBuffer buffer) throws Exception {
		buffer.order(byteOrder);
		byte temp[] = new byte[21];
		buffer.get(temp, 0, 21);
		Mobile_no = new String(temp, "GB2312");
		Mobile_no = Mobile_no.trim();
		buffer.get(temp, 0, 21);
		SPNumber = new String(temp, "GB2312");
		SPNumber = SPNumber.trim();
		TP_pid = buffer.get();
		TP_udhi = buffer.get();
		MessageCoding = buffer.get();
		MessageLength = buffer.getInt();
	}
	private String UCS2String(byte[] msg) {
		int zhong, zhong1;
		String snr = "";
		for (int j = 0; j < this.MessageLength; j += 2) {
			zhong = msg[j];
			if (zhong < 0)
				zhong += 256;
			zhong1 = msg[j + 1];
			if (zhong1 < 0)
				zhong1 += 256;
			zhong = zhong * 256 + zhong1;
			if (zhong == 0)
				break;
			snr = snr + (char) zhong;
		}
		return snr;
	}
	public void setBuffermsg(ByteBuffer buffer) throws Exception {
		buffer.order(byteOrder);
		byte temp[] = new byte[this.MessageLength];
		buffer.get(temp, 0, this.MessageLength);
		// 判断接收信息格式
		switch (MessageCoding) {
		case 0:// ASCII串
			msg = new String(temp).trim();
			break;
		case 3:// 短信写卡操作
			break;
		case 4:// 二进制信息
			break;
		case 8:// UCS2编码
			msg = UCS2String(temp);
			break;
		case 15:// 含GB汉字
			break;
		default:
			break;
		}
	}
	public void read(SocketChannel channel) throws Exception {
		ByteBuffer buffer = ByteBuffer.allocate(STRUCT_SIZE);
		buffer.order(byteOrder);
		channel.read(buffer);
		buffer.flip();
		this.setBuffer(buffer);
		buffer = ByteBuffer.allocate(this.MessageLength);
		buffer.order(ByteOrder.nativeOrder());
		channel.read(buffer);
		buffer.flip();
		msg = new String(buffer.array(), charset);
	}
}

						