webserverrequestthread.java

中移动lbs系统服务器端源码

package cn.netjava.lbs.le;

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


/**
 * 
 * <p>Title:中国移动手机定位系统(LBS) le接口库</p>
 * <p>Description: </p>
 * <p>Company:蓝杰实训 </p>
 * @author www.NetJava.cn 
 * @version 0.1
 */

public class WebServerRequestThread extends Thread {

	public WebServerRequestThread(Socket socket) {
		_socket = socket;
	}

	public void run() {
		InputStream in = null;
		OutputStream out = null;
		try {
			in = _socket.getInputStream();
			out = _socket.getOutputStream();
		} catch (Exception ee) {
			return;
		}

		try {
			String clientIP = _socket.getInetAddress().getHostAddress();
			// if ( !ProvInfo.SyncOrderClientIP.equals("127.0.0.1") &&
			// !clientIP.equals(ProvInfo.SyncOrderClientIP) ){
			// LogManage.ins().logAsDB.info("非法IP "+clientIP+"
			// 访问正向provision接口被阻止");
			// return;
			// }
			_socket.setSoTimeout(30000);
			BufferedReader bin = new BufferedReader(new InputStreamReader(
					_socket.getInputStream()));

			String str = bin.readLine();
			String strtemp = str.concat("\n");
			String str1;
			int contentL = 0; // 内容长度

			/**
			 * 
			 * do while块 主要是得到 内容长度
			 */
			do {
				str1 = bin.readLine().trim();
				strtemp = strtemp.concat(str1).concat("\n");
				if (str1.startsWith("Content-Length:")) {
					try {
						contentL = Integer.parseInt(str1.substring(15,
								str1.length()).trim());
					} catch (Exception ex) {
						System.out.println("read error:" + ex);
						return;
					}
				}
			} while (!str1.equals(""));

			// int index1 = str.indexOf(" ");
			// int index2 = str.indexOf(" ", index1 + 1);
			// if (index1 < 0 || index2 < index1) {
			// return;
			// }
			// String method = str.substring(0, index1).trim(); //得到方法是 GET OR
			// POST
			char culr[] = new char[contentL];
			try {
				bin.read(culr);
			} catch (IOException ex) {
				ex.printStackTrace();
			}
			String readS = new String(culr);
			System.out.println("Recv:" + readS);
			NetJava_LBS_recv.recv(readS);
		} catch (Exception ex) {
			System.out.println(" WebServerRequestThread error:" + ex);
			ex.printStackTrace();
		} finally {
			try {
				in.close();
				out.close();
			} catch (Exception ex) {
			}
		}

	}

	private Socket _socket;
}