chatserverthread.java

一个用java开发的自由聊天涂鸦室小程序,能给你一种不一样的感觉!

package freechat;

import java.io.*;
import java.net.*;
import java.util.*;

class ChatServerThread extends Thread{
	private DatagramSocket socket=null;

	ChatServerThread(){
		super("ChatServer");
		try{
			System.out.println("Chat Server begin");
			socket = new DatagramSocket();
			System.out.println("Chat Server is listening on port:" + socket.getLocalPort());
		} catch(java.net.SocketException e){
			System.err.println("Could not create datagram socket");
		}
	}

	public void run(){
		if(socket==null) return;
		while(true){
			try{
				byte[] buf=new byte[256];
				DatagramPacket packet;
				InetAddress address;
				int port;
				String dString = null;

				packet = new DatagramPacket(buf,256);
				socket.receive(packet);
				address = packet.getAddress();
				port = packet.getPort();
				if(buf[0]=='s') break;
				//buf = packet.getData();

				//buf = dString.getBytes();
				packet = new DatagramPacket(buf,buf.length,address,port);
				socket.send(packet);
			}catch(Exception e){
				System.err.println("******************Exceptio:" + e);
				//e.printStackTrace();
			}
		}

		System.out.println("End Server");		
	}

	protected void finalize(){
		if(socket!=null){
			socket.close();
			socket = null;
			System.out.println("Closing datagram socket.");
		}
	}
}