curveclient.java

java网络编程

package Curve;

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

import javax.swing.JFrame;

public class CurveClient extends Thread{

	private JFrame frame;
	
	MyCanvas mycanvas;
	int point=0;
	static int userid=0;
	int[] user=new int[20];
	DatagramSocket s=null;

	/**
	 * Launch the application
	 * @param args
	 */
	public static void main(String args[]) {
		try {
			for(int i=1;i<=3;i++){
				CurveClient window = new CurveClient();
				window.start();
				try{
					sleep(3000);
				}
				catch(InterruptedException e){
					e.printStackTrace();
				}
				window.frame.setVisible(true);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * Create the application
	 */
	public CurveClient() {
		initialize();
	}

	/**
	 * Initialize the contents of the frame
	 */
	private void initialize() {
		frame = new JFrame("Curve客户端");
		frame.setBounds(100, 100, 500, 375);
		frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		
		mycanvas=new MyCanvas();
		frame.add(mycanvas,"Center");
		frame.show();                        //是窗口显示
	}

	public synchronized void run(){
		
		for(int i=1;i<=10;i++){
			user[i]=(int)(Math.random()*50);
			point=i;					//取得用户温度值个数
		}
		userid++;
		
		System.out.print("用户"+userid+"温度值"+point+"个:");
		for(int i=1;i<=10;i++)
			System.out.print(user[i]+" ");
		System.out.print('\n');
		mycanvas.set(user,point);
		mycanvas.repaint();
		
		try{
			s=new DatagramSocket();			//任意端口号发送	
			InetAddress ip=InetAddress.getLocalHost();
			
			String send=new Pack().SetPack(userid, point, user);
			System.out.println("用户"+userid+"发送:"+send);
			
			byte[] buffer=new String(send).getBytes();			
			DatagramPacket dgp=new DatagramPacket(buffer,buffer.length,ip,8000);
			s.send(dgp);
		}
		catch(IOException e){
			e.printStackTrace();
		}
		finally{
			if(s!=null)
				s.close();
		}
	}
}