2

我有 3 个 Restful 服务,我想将它们作为 Windows 服务托管。我创建了一个安装程序,它将同时托管所有三种服务。我想让我的安装程序有点可配置。我想向同一个安装程序添加新服务,而不需要它来编辑代码。

这是我当前的安装程序代码。在这里,我引用 dll 并托管它们。这只是任何 Windows 宿主项目的普通代码。

App.config 文件

 <services>
  <service name="Service1">
    <endpoint binding="webHttpBinding" contract="IService1" ehaviorConfiguration="REST"/>
  </service>
  <service name="Service2">
    <endpoint binding="webHttpBinding" contract="IService2" behaviorConfiguration="REST"/>
  </service>
  <service name="Service3">
    <endpoint binding="webHttpBinding" contract="IService3" behaviorConfiguration="REST"/>
  </service>
</services>
<behaviors>
  <serviceBehaviors>
    <behavior>
      <serviceMetadata httpGetEnabled="True"/>
      <serviceDebug includeExceptionDetailInFaults="true"/>
    </behavior>
  </serviceBehaviors>

  <endpointBehaviors>
    <behavior name="REST">
      <webHttp automaticFormatSelectionEnabled="true" defaultOutgoingResponseFormat="Json" helpEnabled="true"/>
    </behavior>
  </endpointBehaviors>
</behaviors>

安装程序中的代码。

public partial class Service : ServiceBase
{
    public ServiceHost Service1Host = null;
    public ServiceHost Service2Host = null;
    public ServiceHost Service3Host = null;

    public Service()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {


        Uri Service1_baseAddress = new Uri("http://localhost:9999/Service1");
        Uri Service2_baseAddress = new Uri("http://localhost:9999/Service2");
        Uri Service3_baseAddress = new Uri("http://localhost:9999/Service3");

        if (Service1Host != null)
        {
            Service1Host.Close();
        }
        Service1Host = new ServiceHost(typeof(Service1), Service1_baseAddress);                        
        Service1Host.Open();

        if (Service2Host != null)
        {
            Service2Host.Close();
        }
        Service2Host = new ServiceHost(typeof(Service2), Service2_baseAddress); 
        Service2Host.Open();

        if (Service3Host != null)
        {
            Service3Host.Close();
        }
        Service3Host = new ServiceHost(typeof(Service3), Service3_baseAddress);
        Service3Host.Open();
    }

    protected override void OnStop()
    {
        if (Service1Host != null)
        {
            Service1Host.Close();
            Service1Host= null;
        }
        if (Service2Host != null)
        {
            Service2Host.Close();
            Service2Host = null;
        }
        if (Service3Host != null)
        {
            Service3Host.Close();
            Service3Host = null;
        }
    }
}

我尝试过的就在这里。我从 app.config 中删除了服务端点配置,并在代码中完成了它。我将所有 dll 放在一个文件夹中,并在代码中加载这些 dll。为了获得服务和接口,我在 app.config 中添加参数,如下所示,这将提供服务名称和接口名称以从加载的程序集中检索。一切正常。但是我有一个小问题,我已经在下面解释了。

新建 App.config 文件

<appSettings>
<add key="Service1.dll" value="Service1"/>
<add key="IService1.dll" value="IService1"/>
<add key="Service2.dll" value="Service2"/>
<add key="IService2.dll" value="IService2"/>
<add key="Service3.dll" value="Service3"/>
<add key="IService3.dll" value="IService3"/>
</appSettings>

新的 Windows 主机代码

public partial class Service : ServiceBase
{
    public ServiceHost ServiceHost = null;

    public WinService()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {
    string[] files = Directory.GetFiles(@"C:\Users\Desktop\WindowsHost\dlls", "*.dll");
        for (int i = 0; i < files.Length; i++)
            files[i] = Path.GetFileName(files[i]);

        foreach (var dllName in files)
        {
            string filePath = @"C:\Users\Desktop\WindowsHost\dlls\" + dllName;
            Assembly assembly = Assembly.LoadFrom(filePath);

            string serviceName = ConfigurationManager.AppSettings[dllName];
            string interfaceName = ConfigurationManager.AppSettings["I" + dllName];

            Type serviceToHost = assembly.GetType(serviceName);
            var instance = Activator.CreateInstance(serviceToHost);

            Type contract = service.GetInterface(interfaceName, true);

            string address = dllName.Remove(dllName.LastIndexOf("."));

            Uri baseAddress = new Uri("http://localhost:9999/" + address);

            if (ServiceHost != null)
            {
                ServiceHost.Close();
            }
            ServiceHost = new ServiceHost(instance, baseAddress);
            ServiceEndpoint sEP = ServiceHost.AddServiceEndpoint(contract, new WebHttpBinding(), "");
            WebHttpBehavior webHttpBeh = sEP.Behaviors.Find<WebHttpBehavior>();

            if (webHttpBeh != null)
            {
                webHttpBeh.AutomaticFormatSelectionEnabled = true;
                webHttpBeh.DefaultOutgoingResponseFormat = WebMessageFormat.Json;
                webHttpBeh.HelpEnabled = true;
            }
            else
            {
                WebHttpBehavior newWebHttpBeh = new WebHttpBehavior();
                newWebHttpBeh.AutomaticFormatSelectionEnabled = true;
                newWebHttpBeh.DefaultOutgoingResponseFormat = WebMessageFormat.Json;
                newWebHttpBeh.HelpEnabled = true;
                sEP.Behaviors.Add(newWebHttpBeh);
            }

            ServiceHost.Open();
        }
    }

    protected override void OnStop()
    {
        if (ServiceHost != null)
        {
            ServiceHost.Close();
            ServiceHost = null;
        }
    }
}

我在这里所做的是创建加载的 dll 的实例并将其作为 Windows 服务托管。

ServiceHost = new ServiceHost(instance, baseAddress);

如果您的服务行为将 InstanceContextMode 设置为 single,则此方法可以正常工作。否则它会给出错误。

错误: “服务无法启动。System.InvalidOperationException:为了使用接受服务实例的 ServiceHost 构造函数之一,必须将服务的 InstanceContextMode 设置为 InstanceContextMode.Single。这可以通过 ServiceBehaviorAttribute 进行配置。否则,请考虑使用带有 Type 参数的 ServiceHost 构造函数。”

我尝试像这样修改代码

ServiceHost = new ServiceHost(typeof(serviceToHost), baseAddress);

但它不起作用。请帮忙。有没有其他方法可以实现这一点。

谢谢

4

1 回答 1

1

这是完整的工作代码。我已经根据需要添加了端点和服务行为。我猜不是每个人都需要相同的配置。我取 dll 名称并将其附加到基地址的末尾。因此,它根据 dll 名称为每个服务创建新地址。app.config 中定义的参数应与 dll 的名称完全匹配。例如,我使用三个 dll,如下所示,那么我的 app.config 将如下面的代码所示。

  1. 服务1.dll
  2. 服务2.dll
  3. 服务3.dll

应用程序配置

<appSettings>
 <add key="baseAddress" value="http://localhost:9999/"/>
 <add key="Service1.dll" value="namespace.Service1"/>
 <add key="Service1.dll" value="namespace.IService1"/>
 <add key="Service2.dll" value="namespace.Service2"/>
 <add key="Service2.dll" value="namespace.IService2"/>
 <add key="Service3.dll" value="namespace.Service3"/>
 <add key="Service3.dll" value="namespace.IService3"/>
</appSettings>

Windows 安装程序代码

public ServiceHost[] serviceHost = null;

    public MyService()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {            
        try
        {
            //Get path for the executing assemblly
            string exePath = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);
            //Path to the dlls to be hosted
            string filePath = exePath + "\\DLLsToHost\\";
            //Retrieve only dll files from the folder
            string[] files = Directory.GetFiles(@filePath, "*.dll");

            //get the dll file names
            for (int i = 0; i < files.Length; i++)
                files[i] = Path.GetFileName(files[i]);

            //create an array of ServiceHost type
            serviceHost = new ServiceHost[files.Length];
            //get the base address for the services from config file
            string address = ConfigurationManager.AppSettings["baseAddress"];

            int j = 0;

            foreach (var dllName in files)
            {
                string dllPath = filePath + dllName;
                //Load the dll
                Assembly assembly = Assembly.LoadFrom(@dllPath);
                //Get the class name implementing the service
                string serviceName = ConfigurationManager.AppSettings[dllName];
                //get the interface name implemented by the class
                string interfaceName = ConfigurationManager.AppSettings["I" + dllName];

                if (serviceName == null || interfaceName == null)
                {
                    //Log the error
                }
                else
                {
                    //Get the class implementing the service
                    Type service = assembly.GetType(serviceName);

                    if (service != null)
                    {
                        //Get the interface implemented by the class
                        Type contract = service.GetInterface(interfaceName, true);

                        if (contract != null)
                        {
                            //Create a base address for the service
                            Uri baseAddress = new Uri(address + dllName.Remove(dllName.LastIndexOf(".")));

                            if (serviceHost[j] != null)
                            {
                                serviceHost[j].Close();
                            }

                            serviceHost[j] = new CustomServiceHost(service, baseAddress);
                            //add the service endpoint and contract
                            ServiceEndpoint sEP = serviceHost[j].AddServiceEndpoint(contract, new WebHttpBinding(), "");
                            WebHttpBehavior webHttpBeh = sEP.Behaviors.Find<WebHttpBehavior>();

                            //Set the service and endpoint behaviours
                            if (webHttpBeh != null)
                            {
                                webHttpBeh.AutomaticFormatSelectionEnabled = true;
                                webHttpBeh.DefaultOutgoingResponseFormat = WebMessageFormat.Json;
                                webHttpBeh.HelpEnabled = true;
                                sEP.Behaviors.Add(new BehaviorAttribute());     //Add CORS support
                            }
                            else
                            {
                                WebHttpBehavior newWebHttpBeh = new WebHttpBehavior();
                                newWebHttpBeh.AutomaticFormatSelectionEnabled = true;
                                newWebHttpBeh.DefaultOutgoingResponseFormat = WebMessageFormat.Json;
                                newWebHttpBeh.HelpEnabled = true;
                                sEP.Behaviors.Add(newWebHttpBeh);
                                sEP.Behaviors.Add(new BehaviorAttribute());     //Add CORS support
                            }

                            serviceHost[j].Open();
                        }
                        else
                        {
                            //Log the error
                        }
                    }
                    else
                    {
                        //Log the error
                    }
                }
                j++;
            }
        }
        catch(Exception ex)
        {
            //Throw the exception OR Log it
        }
    }

    protected override void OnStop()
    {
        try
        {
            for (int k = 0; k <= serviceHost.Length - 1; k++)
            {
                if (serviceHost[k] != null)
                {
                    serviceHost[k].Close();
                    serviceHost[k] = null;
                }
            }
        }
        catch (Exception ex)
        {
            //Log
        }
    }
}

欢迎任何更新代码的建议。谢谢。

于 2013-04-30T11:16:23.063 回答