configinfosupplier.java

RMI通讯

package com.vanceinfo.socket.server;

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;

/**
 * @author 谷明亮
 * @description 提供配置信息线程
 */
public class ConfigInfoSupplier implements Runnable {

	private ObjectOutputStream oos = null;
	private Socket server;
	private AbstractConfigInfoObject configInfoObject;

	public ConfigInfoSupplier(Socket server,
			AbstractConfigInfoObject configInfoObject) {
		this.server = server;
		this.configInfoObject = configInfoObject;
	}

	public void run() {
		if (server != null)
			try {
				oos = new ObjectOutputStream(server.getOutputStream());
				oos.writeObject(configInfoObject.getConfigInfoObject());
			} catch (IOException e) {
				// 日志文件处理
			} finally {
				try {
					oos.close();
					server.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
	}
}