curveserver.java

java网络编程

package Curve;

import java.io.*;
import java.net.*;
import javax.swing.JFrame;

public class CurveServer {

	private JFrame frame;
	
	MyCanvas mycanvas;
	int receive[][]=new int[20][20];
	int avg[]=new int[20];
	int userid=0,point=0;

	/**
	 * Launch the application
	 * @param args
	 */
	public static void main(String args[]) {
		try {
			CurveServer window = new CurveServer();
			window.frame.setVisible(true);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * Create the application
	 */
	public CurveServer() {
		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();                        //是窗口显示
		
		try{
			System.out.println("Server Starting...");
			DatagramSocket s=new DatagramSocket(8000);
			byte[] data=new byte[3000];
			DatagramPacket dgp=new DatagramPacket(data,data.length);
			while(true){
				s.receive(dgp);
				String receiveStr=new String(dgp.getData()).trim();

				receive=new Pack().GetPack(receiveStr);
				userid=receive[0][0];
				point=receive[0][1];
				System.out.println("用户"+userid+"平均温度值"+point+"个:");
				
				for(int i=1;i<=point;i++)
					avg[i]=0;               //每次将avg[i]置0
				
				for(int i=1;i<=userid;i++){
					for(int j=1;j<=point;j++)
						avg[j]+=receive[i][j];
				}
				for(int i=1;i<=point;i++){
					avg[i]=avg[i]/userid;
					System.out.print(avg[i]+" ");
				}
				System.out.print('\n');
				
				mycanvas.set(avg,point);
				mycanvas.repaint();
			}
		}
		catch(IOException e){
			e.printStackTrace();
		}
	}

}