c# WCF插件的设计与实现

本文关键字：实现 WCF 插件 | 更新日期: 2023-09-27 17:53:26

我想听听你的建议。我正在开发一个系统，它将在运行时加载插件，并要求它们通过WCF端点可用。

我将有一个MVC 3 Web应用程序，只是真正用于配置，和一个类库(核心)，将加载不同的插件。

我希望你能指导我如何做这件事。我想加载插件，然后能够创建一个WCF端点，注册IIS 7访问到该插件。

提前感谢:)

c# WCF插件的设计与实现

使用Darko的动态IIS托管WCF服务工作的衍生物，您可以实现您想要的东西。让我们从一个我们想要托管的示例服务开始，我们将其称为IMessageBroker，它的契约很简单:

[ServiceContract]
public interface IMessageBroker
{
  [OperationContract]
  string Send(string message);
}

我们将此合同用于服务和MEF导出/导入。我们还将定义一些附加的元数据:

public interface IMessageBrokerMetadata
{
  public string Name { get; }
  public string Channel { get; }
}

由于这是一个简单的项目，我将使用一个简单的静态类来管理用于组合部件的MEF CompositionContainer:

public static class MEF
{
    private static CompositionContainer container;
    private static bool initialised;
    public static void Initialise()
    {
        var catalog = new DirectoryCatalog("bin");
        container = new CompositionContainer(catalog);
        initialised = true;
    }
    public static CompositionContainer Container
    {
        get
        {
            if (!initialised) Initialise();
            return container;
        }
    }
}

为了能够动态地生成WCF服务，我们需要创建一个ServiceHostFactory，它可以访问我们的组合容器来访问我们的类型，所以你可以这样做:

public class MEFServiceHostFactory : ServiceHostFactory
{
    public override ServiceHostBase CreateServiceHost(string constructorString, System.Uri[] baseAddresses)
    {
        var serviceType = MEF.Container
            .GetExports<IMessageBroker, IMessageBrokerMetadata>()
            .Where(l => l.Metadata.Name == constructorString)
            .Select(l => l.Value.GetType())
            .Single();
        var host = new ServiceHost(serviceType, baseAddresses);
        foreach (var contract in serviceType.GetInterfaces())
        {
            var attr = contract.GetCustomAttributes(typeof(ServiceContractAttribute), true).FirstOrDefault();
            if (attr != null)
                host.AddServiceEndpoint(contract, new BasicHttpBinding(), "");
        }
        var metadata = host.Description.Behaviors
            .OfType<ServiceMetadataBehavior>()
            .FirstOrDefault();
        if (metadata == null)
        {
            metadata = new ServiceMetadataBehavior();
            metadata.HttpGetEnabled = true;
            host.Description.Behaviors.Add(metadata);
        }
        else
        {
            metadata.HttpGetEnabled = true;
        }
        return host;
    }
}

本质上，constructorString参数用于传递我们想要的特定服务的元数据名称。接下来，我们需要处理定位这些服务。我们现在需要的是一个VirtualPathProvider，我们可以使用它通过VirtualFile动态地创建实例。提供者看起来像:

public class ServiceVirtualPathProvider : VirtualPathProvider
{
    private bool IsServiceCall(string virtualPath)
    {
        virtualPath = VirtualPathUtility.ToAppRelative(virtualPath);
        return (virtualPath.ToLower().StartsWith("~/services/"));
    }
    public override VirtualFile GetFile(string virtualPath)
    {
        return IsServiceCall(virtualPath)
                   ? new ServiceFile(virtualPath)
                   : Previous.GetFile(virtualPath);
    }
    public override bool FileExists(string virtualPath)
    {
        if (IsServiceCall(virtualPath))
            return true;
        return Previous.FileExists(virtualPath);
    }
    public override System.Web.Caching.CacheDependency GetCacheDependency(string virtualPath, System.Collections.IEnumerable virtualPathDependencies, DateTime utcStart)
    {
        return IsServiceCall(virtualPath)
                   ? null
                   : Previous.GetCacheDependency(virtualPath, virtualPathDependencies, utcStart);
    }
}

我们正在做的是将任何对/Services/的调用映射到MEF派生的端点。该服务需要一个虚拟文件，这就是我们把它们连接在一起的地方:

public class ServiceFile : VirtualFile
{
    public ServiceFile(string virtualPath) : base(virtualPath)
    {
    }
    public string GetName(string virtualPath)
    {
        string filename = virtualPath.Substring(virtualPath.LastIndexOf("/") + 1);
        filename = filename.Substring(0, filename.LastIndexOf("."));
        return filename;
    }
    public override Stream Open()
    {
        var stream = new MemoryStream();
        var writer = new StreamWriter(stream);
        writer.Write("<%@ ServiceHost Language='"C#'" Debug='"true'" Service='"" + GetName(VirtualPath) +
                     "'" Factory='"Core.MEFServiceHostFactory, Core'" %>");
        writer.Flush();
        stream.Position = 0;
        return stream;
    }
}

虚拟文件将从虚拟路径中分离出元数据名称，其中/Services/SampleMessageBroker.svc -> SampleMessageBroker。然后我们用Service="SampleMessageBroker"生成一些表示.svc文件标记的标记。这个参数将被传递给MEFServiceHostFactory，在那里我们可以选择出端点。因此，给定一个示例端点:

[Export(typeof(IMessageBroker)),
 ExportMetadata("Name", "SampleMessageBroker"),
 ExportMetadata("Channel", "Greetings")]
public class SampleMessageBroker : IMessagerBroker
{
  public string Send(string message)
  {
    return "Hello! " + message;
  }
}

我们现在可以在/Services/SampleMessageBroker.svc动态访问它。您可能想要做的是提供一个静态服务，它允许您集成可用的端点，并将其反馈给您的消费客户端。

哦，别忘了连接你的虚拟路径提供程序:

HostingEnvironment.RegisterVirtualPathProvider(new ServiceVirtualPathProvider());
相关文章：