@Override
	public void run() {
		init();
		while (listening){
			byte[] recv= new byte[1024];
        	try {
        		int cnt = is.read(recv); 
				if (cnt==-1){
					listening=false;
					break;
				}
			this.recv(recv,cnt);
			} catch (IOException e) {
				e.printStackTrace();
			}

		}
		
		shutdown();
		
	}