controllisening.java

基于 C/S 模式的网上购物系统

package RegisterAndLogin;
import java.net.*;
import java.io.*;
import java.lang.Thread;
import java.sql.*;
import javax.sql.*;
import java.sql.ResultSet;
import javax.sql.rowset.CachedRowSet;
import java.lang.Thread;
import java.net.*;
import java.io.*;
import java.lang.Thread;
import java.sql.*;
import javax.sql.*;
import java.sql.ResultSet;
import javax.sql.rowset.CachedRowSet;
import java.lang.Thread;
public class ControlLisening extends Thread
{
	private Socket socket=null;
	ObjectInputStream is=null;
	ObjectOutputStream os=null;
	boolean running=true;
	String userName=null;
	boolean onFlag;
	String shopID=null;
	Hall frame=null;
	public ControlLisening(Socket s,Hall frame,ObjectInputStream is,ObjectOutputStream os)
	{
		try
		{
			this.frame=frame;
			socket=s;
			this.is=is;
			this.os=os;
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	public void run()
	{int cou=frame.OnLinelist.getItemCount();
	System.out.println("在线用户个数"+cou);
	for(int i=0;i<cou;i++)
		System.out.print(frame.OnLinelist.getItem(i)+"***");
	
	System.out.println("***************");
	cou=frame.OffLinelist.getItemCount();
	System.out.println("不在线用户个数"+cou);
	for(int j=0;j<cou;j++)
		System.out.println(frame.OffLinelist.getItem(j)+"***");
	System.out.println("***************");
		
		while(running)
		{
			System.out.println("controlthread start");
			try
			{
				String conFlag=(String)is.readObject();
				System.out.println(conFlag);
				if(conFlag.equals(ConstanValue.CON_ONLINE_USER))
				{
				    userName=(String)is.readObject();
				    onFlag=is.readBoolean();
				    System.out.println(userName);
				    UpdateLocalInfoOfUser();
				}
				if(conFlag.equals(ConstanValue.CON_ONLINE_SHOP))
				{
				    shopID=(String)is.readObject();
				    
				    onFlag=is.readBoolean();
				    System.out.println(shopID);
				    UpdateLocalInfoOfShop();
				}
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
		}
	}
	
	//处理控制 更新 用户
	public void UpdateLocalInfoOfUser()
	{
		
		System.out.println("接受到"+userName+"上下线通知");
	}
	
	//处理更新 控制店铺
	public void UpdateLocalInfoOfShop()
	{
		int cou=frame.OnLinelist.getItemCount();
		System.out.println("在线用户个数"+cou);
		for(int i=0;i<cou;i++)
			System.out.print(frame.OnLinelist.getItem(i)+"***");
		
		System.out.println("***************");
		cou=frame.OffLinelist.getItemCount();
		System.out.println("不在线用户个数"+cou);
		for(int j=0;j<cou;j++)
			System.out.println(frame.OffLinelist.getItem(j)+"***");
		System.out.println("***************");
		if(onFlag==true)
		{   System.out.println("接受到"+shopID+"上线通知");			
		    frame.OnLinelist.addItem(shopID);
			frame.OffLinelist.remove(shopID);	
		   
		}
		else
		{	System.out.println("接受到"+shopID+"下线通知");
			
			frame.OnLinelist.remove(shopID);
			frame.OffLinelist.addItem(shopID);
		
		}
	}
	
	public void StopRun()
	{
		running=false;
	}
}