serverthread.java

3G体验手机展示程序 3G体验手机展示程序 3G体验手机展示程序

package com.hongguan.lifeshowclient2;

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

public class ServerThread extends Thread{ 
	int no; 
	Socket socket; 
	Connection con=null;
	Statement stmt=null;
	OutputStream os=null;
	InputStream is=null;
	public Sender sender; 

	static String[] str=new String[10]; 

	public ServerThread(Socket skt,int n) { 
		no=n; 
		socket=skt; 
		for(int i=0;i<10;i++){ 
			str[i]=null; 
		}

		try{ 
			is=socket.getInputStream(); 
			os=socket.getOutputStream();
			sender = new Sender(os);
		} catch(IOException e){
			System.out.println("error...................");
			e.printStackTrace();
		} 
	}

	public void run(){ 
		while(true){ 
			try{ 
				StringBuffer sb = new StringBuffer(); 
				int c = 0;
				//System.out.println("is.read()'s value:"+is.read());
				while (((c = is.read()) != '\n') && (c != -1)) { 
					sb.append((char) c); 
				} 

				if (c == -1) {
					break;
				} 
				System.out.println("Message received - " + sb.toString()); 
				str[no]=sb.toString(); 
				char ch=str[no].charAt(0); 
				int id=ch-'0';
//				sender = new Sender(os);
				//sender.send(str[id]); 
			}catch(Exception e){
				e.printStackTrace();
			} 
		} 
	} 
}