WCF模块服务框架+WCF模块服务托管程序MSH

// 模块主机（基）类 public class ModuleHost : IModuleHost { /* 属性 */ // 是否已加载 public bool IsLoaded { get; } // 是否开启路由 public virtual bool RoutingEnabled { get; } // 模块存放目录 public virtual string ModuleDirectory { get; } // 正在工作模块列表 public IDictionary<string, WorkingModule> WorkingModules { get; } // 令牌处理器，默认为：NullTokenResolver public virtual ITokenResolver TokenResolver { get; } // 端口配置管理器，默认为：XmlPortConfigManager public virtual IPortConfigManager PortConfigManager { get; } /* 主要方法成员 */ // 加载 public void Load(); // 加载核心的实现 protected virtual void LoadCore(); // 卸载 public void Unload(); // 卸载核心的实现 protected virtual void UnloadCore(); // 获取需要提供路由服务的通道上下文类型 public virtual IList<Type> GetChannelContextTypesForRoutingService(); /* 主要事件 */ // 主机加载后触发 public event EventHandler Loaded; // 主机正在加载时触发 public event EventHandler Loading; // 主机卸载后触发 public event EventHandler Unloaded; // 主机正在卸载后触发 public event EventHandler Unloading; // 模块加载失败时触发 public event EventHandler<ModuleLoadFailedEventArgs> ModuleLoadFailed; // 模块状态发生改变时触发 public event EventHandler<ModuleStateChangedEventArgs> ModuleStateChanged; // 工作模块被添加后触发 public event EventHandler<WorkingModuleAddedEventArgs> WorkingModuleAdded; // 工作模块被移除后触发 public event EventHandler<WorkingModuleRemovedEventArgs> WorkingModuleRemoved; /* 执行以上主要事件的默认方法 */ protected virtual void OnLoaded(object sender, EventArgs e); protected virtual void OnLoading(object sender, EventArgs e); protected virtual void OnUnloaded(object sender, EventArgs e); protected virtual void OnUnloading(object sender, EventArgs e); protected virtual void OnModuleLoadFailed(object sender, ModuleLoadFailedEventArgs e); protected virtual void OnModuleStateChanged(object sender, ModuleStateChangedEventArgs e); protected virtual void OnWorkingModuleAdded(object sender, WorkingModuleAddedEventArgs e); protected virtual void OnWorkingModuleRemoved(object sender, WorkingModuleRemovedEventArgs e); } // 令牌处理器接口 public interface ITokenResolver { // 生成模块令牌 string GenerateToken(string serviceName); // 验证模块令牌 bool VerifyToken(string serviceName, string tokenToVerify); } // 端口配置管理器接口 public interface IPortConfigManager { // 获取服务端口 IList<int> ServicePorts { get; } // 根据端口获取配置 NameValueCollection GetConfig(int port); // 根据端口保存配置 void SaveConfig(int port, NameValueCollection configs); // 判断配置项是否合法 bool IsConfigItemValid(string name, string value, out string errorMessage); } // XML端口配置管理器（基）类 public class XmlPortConfigManager : IPortConfigManager { // 获取配置目录 public virtual string ConfigDirectory { get; } // 获取服务端口 public IList<int> ServicePorts { get; } // 根据端口获取配置 public NameValueCollection GetConfig(int port); // 根据端口保存配置 public void SaveConfig(int port, NameValueCollection configs); // 判断配置项是否合法 public bool IsConfigItemValid(string name, string value, out string errorMessage); } // 通道上下文基类 [Serializable] public abstract class ChannelContextBase<TContext> : ChannelContextBase where TContext : ChannelContextBase<TContext>, new() { /* 头部信息 */ // 头部信息的LocalName protected internal virtual string ContextHeaderLocalName { get; } // 头部信息的Namespace protected internal virtual string ContextHeaderNamespace { get; } /* 基本属性 */ // 获取当前通道上下文实例 public static TContext Current { get; set; } // 返回信息（服务器端返回到客户端的信息） public string ReturnMessage { get; set; } // 通过key获取或设置上下文数据 public object this[string key] { get; set; } /* 国际时间相关 */ // 时区 public TimeZoneInfo TimeZone { get; set; } // 根据TimeZone属性转换本地时间为Utc时间 public DateTime ConvertTimeToUtc(DateTime dateTime); // 根据TimeZone属性从Utc时间转换本地时间 public DateTime ConvertTimeFromUtc(DateTime dateTime); /* 服务器端相关（客户端调用无效） */ // 获取当前服务端口 public int GetServicePort(); // 获取当前模块服务名称 public string GetServiceName(); // 获取当前服务端口的配置 public NameValueCollection GetConfig(); // 获取当前请求的原始客户端IP地址 public string GetRemoteEndpointAddress(); // 获取当前请求的客户端IP地址（可指定是否原始客户端） public string GetRemoteEndpointAddress(bool original); } // 模块基类 public abstract class ModuleBase<TContext, TContract, TService> : IModule where TContext : ChannelContextBase<TContext>, new() where TService : TContract, new() { /* 基本属性 */ // 获取令牌 public virtual string Token { get; } // 获取服务名称 public virtual string ServiceName { get; } // 获取服务描述 public virtual string ServiceDescription { get; } // 获取模块状态 public ModuleState State { get; } // 获取通道验证器，默认为：NullChannelVerifier public virtual IChannelVerifier ChannelVerifier { get; } /* 基本方法 */ // 打开模块 public bool Open(); // 关闭模块 public bool Close(); // 模块被框架后 public virtual void OnLoad(); // 模块被卸载后 public virtual void OnUnload(); // 获取打开服务使用的NetTcpBinding public virtual NetTcpBinding CreateNetTcpBinding(); /* 主要事件 */ // 正在打开时触发 public event EventHandler Opening; // 已经打开时触发 public event EventHandler Opened; // 正在关闭时触发 public event EventHandler Closing; // 已经关闭时触发 public event EventHandler Closed; // 失败时触发 public event EventHandler Faulted; /* 执行以上主要事件的默认方法 */ protected virtual void OnOpening(object sender, EventArgs e); protected virtual void OnOpened(object sender, EventArgs e); protected virtual void OnClosing(object sender, EventArgs e); protected virtual void OnClosed(object sender, EventArgs e); protected virtual void OnFaulted(object sender, EventArgs e); } // 通道验证器接口 public interface IChannelVerifier { // 验证通道 VerifyChannelResult VerifyChannel(object contextState, Message message); } // 通道验证器基类 public abstract class ChannelVerifierBase<TVerifier> : IChannelVerifier where TVerifier : ChannelVerifierBase<TVerifier>, new() { // 获取实例 public static IChannelVerifier Instance { get; } // 验证通道 public abstract VerifyChannelResult VerifyChannel(object contextState, Message message); } // 模块客户端类 public static class ModuleClient { // 创建通道：没返