clientthread.java

联通短信平台

// Decompiled by Jad v1.5.7g. Copyright 2000 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/SiliconValley/Bridge/8617/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi 
// Source File Name:   clientThread.java


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

public class clientThread extends Thread
{

	message mess;
	int nRet = 0;
	int k =0; 
	SendMessage SendMessage1;
   
    public clientThread(message mess)
    {
		
		this.mess = mess;
        SendMessage1 = new SendMessage();
    }
	private String getPath() 
	{
		return "c:/test/" ;
	}
	public void run()
	{
		String sfileName = getPath() + "test.ini";
	
		
		Properties prop = new Properties();
		try
		{
			prop.load(new FileInputStream(sfileName));
		}
		catch(IOException ioe)
		{
			System.out.println(" fail to load test.ini file ".concat(String.valueOf(String.valueOf(sfileName))));
			
			SendMessage1.SendMessage(" 获的配置文件test.ini失败 ".concat(String.valueOf(String.valueOf(sfileName))));
		}
		int nSubmit = Integer.parseInt(prop.getProperty("Submit", "1"));
	
		
			do{
				if(nSubmit == 1)
				{
					do
					{
						try
						{
							nRet = mess.sendSubmit();
						}
						catch(Exception ex)
						{
						SendMessage1.SendMessage("发送消息sendSubmit出现异常"+ex.getMessage());
						}
						if(nRet ==-1)
						{
							k++;
							if(k>29)
							{
								break;
							}
							try
							{
								//System.out.println("发送线程无数据切换");
								this.sleep(1000);
							}
							catch(Exception ee)
							{
							System.out.println("发送线程休眠失败");
								SendMessage1.SendMessage("发送线程休眠失败");
							}
						}
					}while(true);
				}
				
		/*
	if(nDeliverRep == 1)
		{
				
			do
			{
					
				nRet = mess.sendDeliverRep();
				if(nRet >= 0)
					break;
				else
				{
					nRet = mess.sendConnect();
						
				}

					
			} while(true);
				
		}
		*/
		if(k>=29)
		{
			try
			{
				nRet = mess.sendActive();
				System.out.println("发送线程发送链路包");
				k=0;
				//System.out.println("线程停止10秒");
				//this.sleep(1000);	
			//	System.out.println("线程重新开始");
			}
			catch(Exception ee)
			{
			System.out.println("线程发生异常"+ee.getMessage());
				SendMessage1.SendMessage("线程发送sendActive链路包发生异常"+ee.getMessage());
			}
		}
		}while(true);

		
	}
    
}