serverthread.java

用java编写的c/s结构的网络社区

package server;
import java.io.*;
import java.net.Socket;
import java.sql.*;

import javax.swing.JTextArea;

public class ServerThread extends Thread
{
	Socket s1;
	DataOutputStream dos;
	DataInputStream dis;
	JTextArea jtaControl;
	String strMeg;
	ServerMessage_member message_member=new ServerMessage_member();
	ServerMessage_Invest message_InvestCorp=new ServerMessage_Invest ();
	ServerMessage_Store message_Store=new ServerMessage_Store();
	public ServerThread(Socket s,JTextArea jtaControl,String strMeg)throws IOException{
		s1=s;
		this.jtaControl=jtaControl;
		this.strMeg=strMeg;
		dos=new DataOutputStream(s1.getOutputStream());
		dis=new DataInputStream(s1.getInputStream());
		this.start();
	}
	public void run(){
		int sort;
		try 
		{
			while(true)
			{
				sort = dis.readInt();
				System.out.println(sort);
				dos.write("ok".getBytes());
				WriteControl(sort,jtaControl,strMeg);
				DealRequest(sort);
			}
				
			
			
		} catch (IOException e) {
			
			jtaControl.append(strMeg+":结束服务\n");
		}
	}
	void WriteControl(int sort,JTextArea jtaControl,String strMeg)
	{
		switch(sort)
		{
		case 1:
			jtaControl.append(strMeg+":请求注册\n");//注册
			break;
		case 2:
			jtaControl.append(strMeg+":请求登录\n");//登录
			break;
		case 3:
			jtaControl.append(strMeg+":请求检查用户名是否已被用\n");//是否存在
			break;
		case 4:
			jtaControl.append(strMeg+":验证帐号密码并请求返回余额\n");//帐号密码验证
			break;
		case 5:
			jtaControl.append(strMeg+":找回密码\n");//找回密码
			break;
		case 6:
			jtaControl.append(strMeg+":重设问题答案\n");
			break; //重设问题
		case 7:
			jtaControl.append(strMeg+":重设密码\n");
			break;//重设密码
		case 8:
			jtaControl.append(strMeg+":改变余额\n");
			break;//改变余额
		case 9:  
			jtaControl.append(strMeg+":序列号验证\n");
			break;               //序列号验证
		case 10:
			jtaControl.append(strMeg+":产品注册\n");//产品注册
			break;
		case 11:
			jtaControl.append(strMeg+":加盟软件公司申请\n");//加盟申请
			break;
		case 12:
			jtaControl.append(strMeg+":查询用户信息\n");//查询用户信息
			break;
		case 13:
			jtaControl.append(strMeg+":申请查询公司信息\n");//查询公司信息
			break;
		case 14:
			jtaControl.append(strMeg+":申请查询软件信息\n");//查询软件信息
			break;
		case 15:
			jtaControl.append(strMeg+":申请软件升级\n");//软件升级
			break;
		case 16:
			jtaControl.append(strMeg+":申请加盟投资公司\n");//investjiameng
			break;
		case 17:
			jtaControl.append(strMeg+":请求查询申请投资的公司\n");
			break;
		case 18:
			jtaControl.append(strMeg+":请求投资项目表\n");
			break;
		case 19://转帐
			jtaControl.append(strMeg+":请求转帐\n");
			break;
		case 20:
			jtaControl.append(strMeg+":请求将货物加入购物车\n");
			break;
		case 21:
			jtaControl.append(strMeg+":请求退回产品\n");
			break;
		}
			
	}
	void DealRequest(int sort)
	{
	
		try
		{
			switch(sort)
			{
			case 1:
				message_member.GetInfo(dos,dis,jtaControl,strMeg,1);//注册
				break;
			case 2:
				message_member.GetInfo(dos, dis,jtaControl,strMeg,2);//登录
				break;
			case 3:
				message_member.GetInfo(dos, dis,jtaControl,strMeg,3);//是否存在
				break;
			case 4:
				message_member.GetInfo(dos, dis,jtaControl,strMeg, 5);//帐号密码验证
				break;
			case 5:
				message_member.GetInfo(dos, dis,jtaControl,strMeg, 4);//找回密码
				break;
			case 6:
				message_member.GetSingleInfo(dis,jtaControl,strMeg, 3);
				dos.write("ok".getBytes());
				message_member.GetSingleInfo(dis,jtaControl,strMeg, 4);
				break; //重设问题
			case 7:
				message_member.GetSingleInfo(dis,jtaControl,strMeg, 2);
				break;//重设密码
			case 8:
				message_member.GetSingleInfo(dis,jtaControl,strMeg, 5);
				break;//改变余额
			case 9:  
				message_InvestCorp.DownLoad(dos, dis,jtaControl,strMeg,2);/** 取出所有项目**/
				break;               
			case 10:
				message_InvestCorp.DownLoad(dos, dis,jtaControl,strMeg,3);/**显示个人竞标的信息**/
				break;
			case 11:
				message_InvestCorp.DownLoad(dos, dis,jtaControl,strMeg,4);/**显示个人得标信息**/
				break;
			case 12:
				message_member.GetInfo(dos, dis,jtaControl,strMeg, 7);//帐号密码验证
				break;
			case 13:
				message_InvestCorp.GetInfo(dos, dis,jtaControl,strMeg,3);/** 任务完成**/
				break;
			case 14:
				message_InvestCorp.GetInfo(dos, dis,jtaControl,strMeg,4);/** 成功竞标**/
				break;
			case 15:
				
				break;
			case 16:
				message_InvestCorp.GetInfo(dos, dis,jtaControl,strMeg, 2);/**项目完成**/
				break;
			case 17:
				message_InvestCorp.GetInfo(dos, dis,jtaControl,strMeg,1);/** 新建投资项目**/
				break;
			case 18:
				message_InvestCorp.DownLoad(dos, dis,jtaControl,strMeg,1);/**返回当前投资**/
				break;
			case 19://转帐
				message_member.GetInfo(dos, dis,jtaControl,strMeg,6);
				break;
			case 20:
				message_Store.GetInfo(dos, dis,jtaControl,strMeg,1);
				break;
			case 21:
				message_Store.GetInfo(dos, dis,jtaControl,strMeg,2);
				break;
			
			}
		}catch (SQLException e) 
		{
			
			e.printStackTrace();
		} catch (IOException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		
	}
}