zhmtcpserverthread.java

ATM开发

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


public class ZHMTCPServerThread implements Runnable {
	private ZongHang ZongHang;
	public ZHMTCPServerThread(ZongHang ZongHang){
		this.ZongHang=ZongHang;
	}
	private Socket sc=null;
	public ZHMTCPServerThread(Socket sc) {
		this.sc=sc;
	}
	public void run() {
		try {
			this.MyRun();
		} catch (IOException e) {
			
			e.printStackTrace();
		}

	}
private void MyRun() throws IOException{
	System.out.println("已经创建线程"+Thread.currentThread().getName()+
	                   "客户机IP："+sc.getInetAddress()+
                       "端口号："+sc.getPort() );
	System.out.println("123");
	BufferedReader br=new BufferedReader(new InputStreamReader(sc.getInputStream()));
	System.out.println("456");
	PrintWriter pw=new PrintWriter(sc.getOutputStream());
	System.out.println("789");
	String line=null;
	System.out.println("111");
	do{
		line=br.readLine();
		System.out.println(""+line);
		String rs=process(line);
    	pw.println(rs);
        pw.flush();
	}while(false);
	System.out.println("线程即将结束运行："+Thread.currentThread().getName());
	pw.close();
	br.close();
	sc.close();
}
		
	
	
	private String process(String data){
		
		String[] a=data.trim().split("\\s+");
		System.out.println(""+a[0]+" "+a[1]+" "+a[2]);
		long s=Long.parseLong(a[0]);
		long m=Long.parseLong(a[1]);
		if(s>100000&&s<199999){
			if(a[2].trim().equals("cun")){
				ZongHang.setSybanksum(ZongHang.getSybanksum()+m);
				return "操作成功";
			}
			else{ZongHang.setSybanksum(ZongHang.getSybanksum()-m);}
			
			return "操作成功";
		}
		if(s>200000&&s<299999){
			if(a[2].trim().equals("cun")){
				ZongHang.setJsbanksum(ZongHang.getJsbanksum()+m);
				return "操作成功";
				
			}
			else{ZongHang.setJsbanksum(ZongHang.getJsbanksum()-m);}
			return "操作成功";
		}
		if(s>300000&&s<399999){
			if(a[2].trim().equals("cun")){
				ZongHang.setNybanksum(ZongHang.getNybanksum()+m);
				return "操作成功";
			}
			else{ZongHang.setNybanksum(ZongHang.getNybanksum()-m);}
			return "操作成功";
		}
		System.out.println(""+ZongHang.getJsbanksum());
		System.out.println(""+ZongHang.getNybanksum());
		System.out.println(""+ZongHang.getSybanksum());
		return "操作失败";
		
}
	
	public static void main(String[] args) {
		

	}

}