chargenclient.java

本光盘包含了本书各章中出现的所有程序的源代码。 1. 如果是Java程序

package Server;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel;
import java.nio.channels.SocketChannel;
import java.nio.channels.WritableByteChannel;

public class ChargenClient extends Thread{

	/**
	 * @param args
	 */
	
	public void run(){

		// TODO Auto-generated method stub
		int port=19;
		
		SocketAddress address=new InetSocketAddress("192.168.1.103",port);
		try {
			SocketChannel client=SocketChannel.open(address);

			client.configureBlocking(false);
		ByteBuffer buffer1=ByteBuffer.allocate(74);
		ByteBuffer buffer2=ByteBuffer.allocate(74);
		WritableByteChannel out=Channels.newChannel(System.out);
		ReadableByteChannel in=Channels.newChannel(System.in);

		while(true){

	
			in.read(buffer2);
			buffer2.put((byte)'\r');
			buffer2.put((byte)'\n');
			buffer2.flip();
			client.write(buffer2);
			buffer2.clear();
			
			

			
			
		}//while
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	
		
	}
	public static void main(String[] args) {
		ChargenClient a=new ChargenClient();
		Listen b=new Listen();
		a.start();
		b.start();
	}

}

class Listen  extends Thread{
	public void run(){


		// TODO Auto-generated method stub
		int port=19;
		
		SocketAddress address=new InetSocketAddress("192.168.1.103",port);
		try {
			SocketChannel client=SocketChannel.open(address);

			client.configureBlocking(false);
		ByteBuffer buffer1=ByteBuffer.allocate(74);
		ByteBuffer buffer2=ByteBuffer.allocate(74);
		WritableByteChannel out=Channels.newChannel(System.out);
		//ReadableByteChannel in=Channels.newChannel(System.in);

		while(true){


			int n=client.read(buffer1);
			//System.out.println("aaaaaaa"+n);
			if(n>0){
				buffer1.flip();
				out.write(buffer1);
				
				buffer1.clear();
				
			}

		}//while
		
//		while(client.read(buffer1)!=1){
//			buffer1.flip();
//			out.write(buffer1);
//			buffer1.clear();
//			
//		}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	
		
	
	}
}