tester.java

移动CMPP2.0 Java SDK

package cmpp.v2_0;

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

import cmpp.*;
//import com.neusoft.utils.*;

public class Tester {
	
		public static void main(String[] args)
	      	throws FileNotFoundException,IOException,Exception,ClassNotFoundException
	      	{
			
				String result=Tester.send("hello","12233333333","","");
	      	}

	      	public static String send(String messageContent, String PhoneNumber,String desiredDeliveryTime, String deliveryExpirationTime)
	      	throws FileNotFoundException,IOException,Exception,ClassNotFoundException
	      	{
	      		return send(messageContent.getBytes(), PhoneNumber,"","");
	      	}      	      	
	      	
	      	public static String send(byte[] data, String PhoneNumber,String desiredDeliveryTime, String deliveryExpirationTime)
	      	throws FileNotFoundException,IOException,Exception,ClassNotFoundException
	      	{
	      		//System.out.println("next 2 continue ****	*****");
	      		
	      		Socket so=null;
	         	OutputStream out=null;
	         	InputStream input=null;
	         	Connect connect=null;
	         	ConnectResp connectResp=null;

	         	CMPP cmpp= new CMPP();
	         	String result="over";
			try{
	           		connect=new Connect();
	           		connect.setSourceAddr("99999");
	           		connect.setSharedSecret("");
	           		
           		int err;

				System.out.println("begin socket connect---------------");
	           	so=new Socket("127.0.0.1", 7890);
	           	System.out.println("ok socket connect -----------------");
        	   	out=new DataOutputStream(so.getOutputStream());
           		input = new DataInputStream(so.getInputStream());

           		err=connect.write(out);//发送bind
           		
           		System.out.println(connect.toString());
           		System.out.println("send connect OK"); ///----------------------2

           		if(err!=0)   		{
	           			result="BIND命令执行失败";
	               			return result;
               			
           		}
	          	
	          		System.out.println("recv bind_resp  111");
	          		CMPP tmp=cmpp.read(input);//接收sgip消息
	          		
	          		System.out.println("recv bind_resp   222");
	          		if(tmp.getCommandID()==CMPP.ID_CMPP_CONNECT_RESP)          		
	          		{
	          			connectResp=(ConnectResp)tmp;//强制转换
	               		System.out.println(connectResp.toString());
	           		}

	          		System.out.println("ok bind_resp");
	          		
	          		Submit submit = new Submit();
	          		submit.setServiceId("WAP");
	          		submit.setSrcId("9990011");
	          		submit.setMsgSrc("99999");
	          		submit.setFeeType("01");
	          		submit.setMsgText("你好", 15);
	          		submit.addDestTerminalId(PhoneNumber);
	          		submit.addDestTerminalId("1111123123");
	          	          		
	          		submit.write(out);//发送submit
	          		System.out.println("******Send the SMS:");//---------------------6

					System.out.println(" recv submit resp");
					
					tmp=cmpp.read(input);
					
		            System.out.println("submit resp id:  "+ tmp.getCommandID());	
	          		if(tmp.getCommandID()==CMPP.ID_CMPP_SUBMIT_RESP) {
	              			SubmitResp submitresp=(SubmitResp)tmp;//强制转换
	              			System.out.println(submitresp.toString());
		           	}

		              	//System.out.println("ok submit resp");
	          		
	          		ActiveTest activeTest = new ActiveTest();
	          		activeTest.write(out);
	          		System.out.println(activeTest.toString());
	          		tmp = cmpp.read(input);
	          		if(tmp.getCommandID()==CMPP.ID_CMPP_ACTIVE_TEST_RESP) {
	          			ActiveTestResp resp = (ActiveTestResp)tmp;
	          			System.out.println(resp.toString());
	          		}
	          		
	          		Deliver deliver = new Deliver();
	          		deliver.setDestId("123123");
	          		deliver.setMsgText("你好",15);
	          		deliver.setRegisteredDelivery(1);
	          		deliver.setSrcTerminalId("13330113123");

	          		deliver.write(out);
	          		System.out.println(deliver.toString());
	          		tmp = cmpp.read(input);
	          		if(tmp.getCommandID()==CMPP.ID_CMPP_DELIVER_RESP) {
	          			DeliverResp resp = (DeliverResp)tmp;
	          			System.out.println(resp.toString());
	          		}
	          		

	          		Terminate unbind=new Terminate();
	        	      	System.out.println("send unbind");
	              		unbind.write(out);//发送unbind
	              		System.out.println("receive unbind resp");
	              		tmp=cmpp.read(input);
	              		
	              	if(tmp.getCommandID()==CMPP.ID_CMPP_TERMINATE_RESP)
	              		{
	              		TerminateResp Unresp=(TerminateResp)tmp;

	              		}
	              		
	             		out.close();
	             		so.close();
	            		
	         	} catch (CMPP_Exception e){
	              		System.out.println(e.toString());
	           	}
	         	catch (Exception e) {
	            		System.out.println(e.toString());
	         	} 
			
			System.out.println("result="+result);
			         	
	         	return result;
	       }

}