smssender.java~1~

移动CMPP3.0协议短信网关连接程序

import com.huawei.smproxy.*;
import com.huawei.insa2.comm.cmpp.message.*;
import com.huawei.insa2.comm.cmpp30.message.*;
import com.huawei.insa2.util.*;
import java.util.*;

public class Demo30 {
    private static Args args;

    private static SMProxy30 myProxy = null;
    static byte[] msg_Id = null;
    //static Date   Time;
    static int query_Type = 0;
    static String query_Code = " ";
    static String reserve = " ";
    static int pk_Total = 1;
    static int pk_Number = 1;
    static int registered_Delivery = 0;
    static int msg_Level = 0;
    static String service_Id = "11"; //业务标识
    static int fee_UserType = 0;
    static String fee_Terminal_Id = " "; //无意义怎么填写
    static int fee_Terminal_Type = 0;
    static int tp_Pid = 0;
    static int tp_Udhi = 0;
    static int msg_Fmt = 15;
    static String msg_Src = "901234"; //sp_id
    static String fee_Type = "01";
    static String fee_Code = "150";
    static Date valid_Time;
    static Date at_Time;
    static String src_Terminal_Id = "011234"; //sp的服务代码
    static String[] dest_Terminal_Id = {"13666666688"};
    static int dest_Terminal_Type = 0;
    static byte[] msg_Content = {'1','2'};
    static String LinkID ="12";//一定要写,否则会报错

    public Demo30() {
    }

   /* public static void main(String[] a) throws Exception {
        try {
            args = new Cfg("app.xml", false).getArgs("CMPPConnect");

           // String loginName = "user";
           // String loginPass = "pwd";
           // args.set("source-addr", loginName);
           // args.set("shared-secret", loginPass);
            myProxy = new SMProxy30(args);
            CMPP30SubmitMessage submitMsg = new CMPP30SubmitMessage(pk_Total,
                    pk_Number, registered_Delivery, msg_Level, service_Id,
                    fee_UserType, fee_Terminal_Id, fee_Terminal_Type, tp_Pid,
                    tp_Udhi, msg_Fmt, msg_Src, fee_Type, fee_Code, valid_Time,
                    at_Time, src_Terminal_Id, dest_Terminal_Id,
                    dest_Terminal_Type, msg_Content, LinkID);
            myProxy.send(submitMsg);
            String stateDesc = myProxy.getConnState();
            System.out.println(stateDesc);
             //String stateDesc = myProxy.getConnState();
            //myProxy.close();

        } catch (Exception e) {
            System.out.println(e.toString());
            //异常处理
        }
      //  Thread.sleep(11000) ;

    }*/
    public static void main(String[] args) 
    {         SendThread sendthread = new SendThread();  
    	  } 
    
    
    public class SendThread extends Thread 
    { 
    	private boolean shutdown;    
    	 private SMProxy proxy = null;   
    	   public SendThread() {        
    	   	 try {  args = new Cfg("app.xml", false).getArgs("CMPPConnect");  
    	   	 	      myProxy = new SMProxy30(args);      
    	   	 	       } catch (java.io.IOException e) {        
    	   	 	       	     e.printStackTrace();            
    	   	 	       	      throw new IllegalStateException("初始化发送线程出错");       
    	   	 	       	        }   
    	   	 	       	  } 
    	   	 	       	  
    
      }
      
       public void run() {        
       	 try { while (!shutdown && !isInterrupted()) 
       	         	{ 
       	         		
       	         		//Message msg = Message.getMessage();          
       	 		       //  proxy.send(msg.toCMPPSubmitMessage());                
       	 		        //  msg.markSended(); 
       	 		        CMPP30SubmitMessage submitMsg = new CMPP30SubmitMessage(pk_Total,
                    pk_Number, registered_Delivery, msg_Level, service_Id,
                    fee_UserType, fee_Terminal_Id, fee_Terminal_Type, tp_Pid,
                    tp_Udhi, msg_Fmt, msg_Src, fee_Type, fee_Code, valid_Time,
                    at_Time, src_Terminal_Id, dest_Terminal_Id,
                    dest_Terminal_Type, msg_Content, LinkID);
                     myProxy.send(submitMsg);  
       	 		                    
       	 		          Thread.sleep(100);         
       	 		              }       
       	 		            } catch (java.io.IOException e) {      
       	 		            	       e.printStackTrace();          
       	 		            	           throw new IllegalStateException("发送失败,发送线程终止");      
       	 		            	               } catch (InterruptedException e) {          
       	 		            	               	    Thread.currentThread().interrupt();      
       	 		            	               	       }       
       	 		         proxy.close();    
       	 	 }
       }