java服务器端线程体会

一个完整的项目包括服务器和客服端

服务器端初步编写:

(1)

服务器端应用窗口的编写 (服务器类Server):

包括窗口和组件的一些设置, 添加一些客服端的元素,如客服端在线用户表(Vector), 服务端接口ServerSocket, 服务端线程ServerThread

其次就是组件的事件监听以及相应的事件方法

(2)

服务器线程的编写 (服务器线程类 ServerThread):

服务器线程起分配服务器代理线程作用,接受客服端的连接同时为其分配一个专用的服务器代理线程.

编写相对简单,给出服务器(Server) 通过其服务端接口(ServerSocket)监听客服端的连接(Socket),同时为其分配代理线程(ServerAgentThread)

public class ServerThread extends Thread
{
    Server father; //声明Server的引用
    ServerSocket ss;//声明ServerSocket的引用
    boolean flag=true;
    public ServerThread(Server father)
    {//构造器
        this.father=father;
        ss=father.ss;
    }
    public void run()
    {
        while(flag)
        {
            try
            {
                Socket sc=ss.accept();//等待客户端连接
                ServerAgentThread sat=new ServerAgentThread(father,sc);
                sat.start();//创建并启动服务器代理线程
            }
            catch(Exception e)
            {
                e.printStackTrace();
            }
        }
    }
}

(3)

服务器代理线程(ServerAgentThread) :代理线程对应相应的客服端起到接受发送信息作用一个服务器代理线程与一个客服端唯一对应

服务器代理线程类是服务器主要类,

其中包括一些基本的代理线程内容如服务器(Server) 客服端连接(Socket) 数据输入输出(DateInputStream DateOutputStream)

还有与客服端的数据的一些交流方法, 线程run方法起判断客服端信息作用

public class ServerAgentThread extends Thread
{
    
	Server father;//声明Server(服务器Server)的引用
	Socket sc;//声明Socke(客服端接口Socket)t的引用
	DataInputStream din;//声明数据输入流与输出流
	DataOutputStream dout;
	boolean flag=true;//控制线程的生命周期
	public ServerAgentThread(Server father,Socket sc)
	{
                //构造方法一般初始化 服务器 客服端接口 还有应用端接口数据输入输出
		this.father=father;
		this.sc=sc;
		try
		{
			din=new DataInputStream(sc.getInputStream());//创建数据输入流
			dout=new DataOutputStream(sc.getOutputStream());//创建数据输出流
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	public void run()
	{
		while(flag)
		{
			try
			{
				String msg=din.readUTF().trim();
                                //接收客户端传来的信息判断并作出相应的回应
                                //其中单个回应一般包含对服务器端的操作数据回应 以及对客服端的操作数据回应
		 		if(msg.startsWith("c"))//收到新用户的信息
				{
					this.nick_name(msg);
				}
				else if(msg.startsWith("<#CLIENT_LEAVE#>")){
					this.client_leave(msg);
				}
				else if(msg.startsWith("<#TIAO_ZHAN#>")){
					this.tiao_zhan(msg);
				}
				else if(msg.startsWith("<#TONG_YI#>")){
					this.tong_yi(msg);
				}
				else if(msg.startsWith("<#BUTONG_YI#>")){
					this.butong_yi(msg);
				}
				else if(msg.startsWith("<#BUSY#>")){
					this.busy(msg);
				}
				else if(msg.startsWith("<#MOVE#>")){
					this.move(msg);
				}
				else if(msg.startsWith("<#RENSHU#>")){
					this.renshu(msg);
				}	
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
		}
	}


//单个操作方法的书写
//此处省略几个
        //新用户
	public void nick_name(String msg)
	{
		try
		{
			String name=msg.substring(13);//获得用户的昵称
			this.setName(name);//用该昵称给该线程取名
			Vector v=father.onlineList;//获得在线用户列表
			boolean isChongMing=false;//重名flag
			int size=v.size();//获得用户列表的大小
			for(int i=0;i");//将重名信息发送给客户端
				din.close();//关闭数据输入流
				dout.close();//关闭数据输出流
				
                                //重点部分 重名需要终止分配的该服务器代理线程以免产生安全问题 
                                sc.close();//关闭Socket
				flag=false;//终止该服务器代理线程
			}
			else//如果不重名
			{
				v.add(this);//将该线程添加到在线列表
				father.refreshList();//刷新服务器在线信息列表
				String nickListMsg="";
				size=v.size();//获得在线列表大小
    //(实时更新)
				for(int i=0;i|1|2|3|4|5|6|7
				Vector tempv=father.onlineList;
				size=tempv.size();
				for(int i=0;i"+this.getName()+"上线了...");
					}
				}
			}
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
		
	}
            
}    


//用户下线
public void client_leave(String msg){
		try{
			Vector tempv=father.onlineList;//获得在线列表
			tempv.remove(this);//移除该用户代理线程
			int size=tempv.size();
			String nl="<#NICK_LIST#>";
			for(int i=0;i"+this.getName()+"离线了...");
				//组织信息的在线用户列表
				nl=nl+"|"+satTemp.getName();
			}
			for(int i=0;i

java-通用知识说明

java服务器端线程体会

相关

标签