package com.fileup.upfileclient;

import java.io.File;
import java.io.FileInputStream;
import java.util.Date;

import javax.xml.namespace.QName;

import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import com.fileup.util.UtilFile;

/**
 * webservice 文件上传测试代码
 * 
 * @author root
 * 
 */
public class FileUploadClient {
	
	public static void main(String[] args) throws Exception {
		//指定要上传文件的路径
	    String fileName = "C:\\Users\\root\\Desktop\\activation-1.1.jar";
		RPCServiceClient sc = new RPCServiceClient();
		Options options = sc.getOptions();
		EndpointReference erf = new EndpointReference(
				"http://localhost:8088/FileUploadInfo/services/upload_service");
		options.setTo(erf);
		
		File file = new File(fileName);
		FileInputStream in = new FileInputStream(file);
		byte[] bs = new byte[in.available()];
		in.read(bs);
		
		Object[] opAddEntryArgs = new Object[] { "测试上传", UtilFile.fileEndName(fileName) ,bs };
		if (in != null) {
			in.close();
		}
		// 设置返回值类型
		Class<?>[] classes = new Class<?>[] { String.class };
		// 命名空间和方法名称
		QName qname = new QName("http://upservice.fileup.com", "uploadFile");
		// 执行文件上传，接收返回值
		Object returnValue = sc.invokeBlocking(qname,
				opAddEntryArgs, classes)[0];
		System.out.println(new Date() + " 文件上传结束，返回值：" + returnValue);
	}
}