dataprocessservice.java

这是java开发的数据处理服务程序 很值得参考学习!!!!!!!!!!!!!!1

/*
 * Created on 2008-2-28
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package org.merrill.examples.services.dataprocess.impl;

import java.io.*;
import java.rmi.RemoteException;

import org.globus.wsrf.Resource;
import org.globus.wsrf.ResourceProperties;
import org.globus.wsrf.ResourceProperty;
import org.globus.wsrf.ResourcePropertySet;
import org.globus.wsrf.impl.ReflectionResourceProperty;
import org.globus.wsrf.impl.SimpleResourcePropertySet;
//import org.merrill.examples.dataprocess.DataProcessService.DataProcess;
import org.merrill.examples.dataprocess.DataProcessService.DataProcessResponse;
import org.merrill.examples.dataprocess.DataProcessService.Dataprocess;
import org.merrill.examples.dataprocess.DataProcessService.GetValueRP;
import org.merrill.examples.services.dataprocess.impl.DataProcessQName;



/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class DataProcessService implements Resource, ResourceProperties{
	private ResourcePropertySet propSet;
	private String FileName;
    private String value1;
    private int value;
    private String lastOp;
	public DataProcessService() throws RemoteException{
		/* Create RP set */
		this.propSet = new SimpleResourcePropertySet(DataProcessQName.RESOURCE_PROPERTIES);

		/* Initialize the RP's */
		try {
			ResourceProperty valueRP = new ReflectionResourceProperty( DataProcessQName.FileName, "Value", this);
			this.propSet.add(valueRP);
									
		} catch (Exception e) {
			throw new RuntimeException(e.getMessage());
		}
	}
	
	public int getValue() {
		return value;
	}

	public void setValue(int value) {
		this.value = value;
	}

	public String getLastOp() {
		return lastOp;
	}

	public void setLastOp(String lastOp) {
		this.lastOp = lastOp;
	}
	
	public  DataProcessResponse  dataprocess(Dataprocess params) throws IOException{
	    FileName=params.getFileName();
	    String line,read;
		FileReader I1=new FileReader(FileName);
		BufferedReader I2=new BufferedReader(I1);
		int j=0,k =0,q=0,ran;
		double max;
		while((line=I2.readLine())!=null){   
		        j++;   
		        String[] array = line.split(" ");
				k=array.length;
		  }
		System.out.println(j+"test"+k);
	    double[][] data=new double[j][k];
	    double[] maxn=new double[k];
	    FileReader Q1=new FileReader(FileName);
		BufferedReader Q2=new BufferedReader(Q1);
		while((read=Q2.readLine())!=null)
		{	
			 String[] array = read.split(" ");
			 for(int i=0;i<array.length;i++)
			    {
			       String m=array[i];
			       
			       int e=Integer.parseInt(m);   
			       data[q][i]=e;
			      // System.out.println(data[1][i]);
			    }
		   q++;
		}
		Q2.close();
	for(int t=0;t<k;t++)
	{   max=0;
		for(int n=0;n<j;n++)
		{
			if(max<data[n][t])
			{
				max=data[n][t];
				maxn[t]=max;
			}
		}
		
		}	
	FileOutputStream O1=new FileOutputStream("D:\\Process.txt");
	OutputStreamWriter O2=new OutputStreamWriter(O1);
	for(int y=0;y<j;y++)
	{
		for(int l=0;l<k;l++)
		{
			double w=data[y][l]/maxn[l];
			
			
			w=w+Math.random();
			if(w>1)
			{
				w=w-1;
			}
			else if(w<0)
			{
				w=w+1;
			}
			
			//System.out.println(data[y][l]);
			//System.out.println(maxn[l]);
			java.text.DecimalFormat  df=new  java.text.DecimalFormat("#.##");
			//System.out.println(df.format(w));
			String v=String.valueOf(df.format(w));
			O2.write(v+" ");
			//System.out.println(v);
			O2.flush();
		}
		O2.write('\n');
	}
	value1="work have been down";
	return new DataProcessResponse();
	}
	
	public String getValueRP(GetValueRP params) throws RemoteException {
		return value1;
	}
	public ResourcePropertySet getResourcePropertySet() {
		return this.propSet;
	}
}