chatanotherside.java

JAVA网络编程电子书及源码

package net;

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