chatoneside.java

JAVA网络编程电子书及源码

package net;

import java.io.*;
import java.net.*;
import java.util.*;
import sun.net.*;
/**
 * 在这里插入类型说明。
 * 建立日期：(00-8-2 21:52:10)
 * @程序设计者：
 */
public class ChatOneSide {
/**
 * ChatOneSide 构造子注释。
 */
public ChatOneSide() {
	super();
}
/**
 * 启动该应用程序。
 * @param args 命令行参数数组
 */
public static void main(java.lang.String[] args) {
	try{
		DatagramSocket chat_side1_socket=new DatagramSocket(8000);
		System.out.println("hello ! I am glad to meet you on port: "+chat_side1_socket.getLocalPort());
		byte[] buffer_side1_for_receive =new byte[50];
		byte[] buffer_side1_for_send=new byte[50];
		InetAddress host_address=InetAddress.getByName("lizhi-11");
	    int chat_input;
	    for (int count=0;;count++){
	    	for (int j=0;j<50;j++){
				buffer_side1_for_receive[j]=buffer_side1_for_send[j]=(byte)' ';
		    }
	        for(int i=0;(i<50)&&((chat_input=System.in.read())!='\n');i++){
				buffer_side1_for_send[i]=(byte)chat_input;
	        }
	        DatagramPacket packet_send_to_side1=new DatagramPacket(buffer_side1_for_send,50,host_address,9000);   
	        chat_side1_socket.send(packet_send_to_side1);
	        DatagramPacket packet_receive_from_side2=new DatagramPacket(buffer_side1_for_receive,50);
	        chat_side1_socket.receive(packet_receive_from_side2);
	       // System.out.println("received from IP address&port: "+packet_receive_from_side2.getAddress().toString()
		       // +"\t\t"+packet_receive_from_side2.getPort());
	        System.out.print("reponse:  ");
	        for (int k=0;k<50;k++){
	            System.out.print((char)buffer_side1_for_receive[k]);
	        }
	        if (((char)buffer_side1_for_receive[0]=='b')&&((char)buffer_side1_for_receive[1]=='y')
		        &&((char)buffer_side1_for_receive[2]=='e')){
			        buffer_side1_for_send[0]=(byte)'b';
			        buffer_side1_for_send[1]=(byte)'y';
			        buffer_side1_for_send[2]=(byte)'e';
			        chat_side1_socket.send(packet_send_to_side1);
			        break;
		        }
			        
	    }
	    chat_side1_socket.close();
	}catch(Exception e){e.printStackTrace();}
}
	    
	    
	    
	    
	    
	    
	    
	    
}