network.java

该模块实现网上邻居间的聊天功能,采用UDP传输模式,便用java内部功能实现

import java.lang.*;
import java.awt.*;
import java.net.*;
import java.awt.event.*;

class network extends Frame implements Runnable 
{
	
	Button B1;
	Label L1,L2;
	TextField text1;
	TextArea text2;
	List list1;

	public network()
	{
		this.setLayout(null);
		L1 = new Label("对方IP:");
		L1.setBounds(10,30,60,30);
		this.add(L1);
		L2 = new Label("发言:");
		L2.setBounds(10,355,30,30);
		this.add(L2);
		text1 = new TextField("127.0.0.1",20);
		text1.setBounds(75,40,200,25);
		this.add(text1);
		//text2 = new TextField();
		//text2.setBounds(45,355,350,65);
		///this.add(text2);
		text2 = new TextArea("",5,20,1);
		text2.setBounds(45,355,350,65);
		this.add(text2);
		
		B1 = new Button("send");
	    B1.setBackground(Color.white);
		B1.setBounds(400,395,60,25);
		B1.addMouseListener(new myMouseListener());
		this.add(B1);
		list1 = new List(15);
		list1.setBounds(15,70,450,250);
		this.add(list1);
		this.addWindowListener(new WindowAdapter()
		{
			public void windowClosing(WindowEvent e)
			{
				System.exit(0);
			}
		});
		this.setBackground(Color.gray);
		this.setTitle("使用UDP的网络聊天程序");
		this.setBounds(100,100,480,430);
		this.setVisible(true);
	}
	public void run()
	{
		while(true)
		{
			byte[] buf = new byte[100];
			try
			{
				DatagramSocket DS = new DatagramSocket(2222);
				DatagramPacket DP = new DatagramPacket(buf,buf.length);
				DS.receive(DP);
				list1.add("来自"+DP.getAddress().getHostAddress()+":"+DP.getPort()+">"+new String(buf).trim());
				DS.close();
				Thread.sleep(200);
			} 
				catch(Exception excep){}
		}
	}
	class myMouseListener extends MouseAdapter
	{
		public void mouseClicked(MouseEvent e)
		{
			String msg = text2.getText().trim();
			String ipStr = text1.getText().trim();
			try
			{
				DatagramSocket DS = new DatagramSocket();
				DatagramPacket DP = new DatagramPacket(msg.getBytes(),msg.getBytes().length,InetAddress.getByName(ipStr),2222);
				DS.send(DP);
				list1.add("送出:"+msg.trim());
				DS.close();
			}
			catch(Exception excep){}
		}
	}
	
	public static void main(String[] args) 
	{
		network Form1 = new network();
		Thread threadObj = new Thread(Form1);
		threadObj.start();
	}
}