sendtest2.java

cmpp3.0程序

package com.hotct.mytest;

import com.hoten.cmpp.message.*;

import java.net.*;
import java.text.*;
import java.io.*;

public class Sendtest2 {
	final String SMG_Url = "192.168.0.79";
	final int SMG_Port = 7890;
	final String SPNumber = "02939";

	public static void main(String[] args) {
		Sendtest2 atestprocesse = new Sendtest2();
	}

	public Sendtest2() {
		Socket so = null;
		DataOutputStream out = null;
		InputStream input = null;
		try {
			// 1、建立和SMG的socket连接
			so = new Socket(SMG_Url, SMG_Port);
			out = new DataOutputStream(so.getOutputStream());
			input = new DataInputStream(so.getInputStream());
			System.out.println("1、建立和SMG的socket连接");

			// 2、向SMG发送connect命令
			CMPPConnectMessage connmsg = new CMPPConnectMessage();
			String time = CTime.getTime(CTime.YYMMDDhhmm);
			System.out.println(time);
			MD5 md5 = new MD5();
			connmsg.sSP_AUTH = md5.getMD5ofStr("901234" + "000000000" + "1234"
					+ time);
			System.out.println(connmsg.sSP_AUTH);
			connmsg.nSequenceID = 1;
			connmsg.nCommandID = 1;
			connmsg.sSP_ID = "901234";
			connmsg.nVersion = 1;
			connmsg.nTimestamp = 2007;
			connmsg.nMsgSize = 0;

			String strconnmsg = connmsg.nCommandID + connmsg.nSequenceID
					+ connmsg.nMsgSize + connmsg.sSP_ID + connmsg.sSP_AUTH
					+ connmsg.nVersion + connmsg.nTimestamp;

			out.write(strconnmsg.getBytes());
			out.flush();

			System.out.println("2、向SMG发送bind命令");

			// 3、接收Bind_Resp
			// input.read();

			// 4、向SMG发送Submit命令

			// 5、接收Submit_Response

			// 6、向SMG发送Unbind

			// 7、接收Unbind_Response

			// 8、关闭Socket连接
			out.close();
			so.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}