package com.caicongyang.provider;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.Method;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;

import com.caicongyang.server.SayHelloService;
import com.caicongyang.server.SayHelloServiceImpl;

/**
 * 
 * <p> 
 * Title: Provider.java 
 * Package com.caicongyang.provider 
 * </p>
 * <p>
 * Description: RPC服務提供者，供客戶端呼叫
 * <p>
 * @author Tom.Cai
 * @created 2016-2-23 下午10:31:40 
 * @version V1.0 
 *
 */
public class Provider {
	
	public static void main(String[] args) {
		ServerSocket server =  null;
		ObjectOutputStream out = null;
		try {
			server = new ServerSocket(8080);
			Socket socket =null;
			
			while(true){
				System.out.println("---開始監聽---");
				socket = server.accept();
				ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
				String interfaceName = input.readUTF(); //介面名稱
				String methodName = input.readUTF(); //方法名稱
				Class<?>[] parameterType = (Class<?>[]) input.readObject(); //方法型別
				Object[] arguments = (Object[]) input.readObject();    //引數列表
				System.out.println("接收到的引數："+Arrays.toString(arguments));
				
				//根據介面名稱獲取class
				Class<?> serviceInterfaceClass = Class.forName(interfaceName);
				//根據方法名稱和引數型別反射得到方法
				Method method = serviceInterfaceClass.getMethod(methodName, parameterType);
				//服務例項化（這裡做簡單處理，正常應該根據得到的介面名稱serviceInterfaceClass獲取對應的service,但本demo只提供一個服務）
				SayHelloService service = new SayHelloServiceImpl();
				
				//反射執行這個方法
				Object result = method.invoke(service, arguments);
				
				//寫會處理結果
				out = new ObjectOutputStream(socket.getOutputStream());
				out.writeObject(result);
				
				
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				out.close();
			} catch (IOException e1) {
				e1.printStackTrace();
			}
			if(server!=null){
				try {
					server.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
				server = null;
			}
		}
	}
}