WCF绑定netTcpBinding寄宿到控制台应用程序

契约

新建一个WCF服务类库项目,在其中添加两个WCF服务:GameService,PlayerService

代码如下:

[ServiceContract]
public interface IGameService
{
    [OperationContract]
    Task<string> DoWork(string arg);
}
public class GameService : IGameService
{
    public async Task<string> DoWork(string arg)
    {
        return await Task.FromResult($"Hello {arg}, I am the GameService.");
    }
}
[ServiceContract]
public interface IPlayerService
{
    [OperationContract]
    Task<string> DoWork(string arg);
}
public class PlayerService : IPlayerService
{
    public async Task<string> DoWork(string arg)
    {
        return await Task.FromResult($"Hello {arg}, I am the PlayerService.");
    }
}

服务端

新建一个控制台应用程序,添加一个类 ServiceHostManager

public interface IServiceHostManager : IDisposable
{
    void Start();
    void Stop();
}

public class ServiceHostManager<TService> : IServiceHostManager
    where TService : class
{
    ServiceHost _host;

    public ServiceHostManager()
    {
        _host = new ServiceHost(typeof(TService));
        _host.Opened += (s, a) => {
            Console.WriteLine("WCF监听已启动!{0}", _host.Description.Endpoints[0].Address);
        };
        _host.Closed += (s, a) =>
        {
            Console.WriteLine("WCF服务已终止!{0}", _host.Description.Endpoints[0].Name);
        };
    }
    public void Start()
    {
        Console.WriteLine("正在开启WCF服务...{0}", _host.Description.Endpoints[0].Name);
        _host.Open();
    }
    public void Stop()
    {
        if (_host != null && _host.State == CommunicationState.Opened)
        {
            Console.WriteLine("正在关闭WCF服务...{0}", _host.Description.Endpoints[0].Name);
            _host.Close();
        }
    }
    public void Dispose()
    {
        Stop();
    }

    public static Task StartNew(CancellationTokenSource cancelTokenSource)
    {
        var theTask = Task.Factory.StartNew(() =>
        {
            IServiceHostManager shs = null;
            try
            {
                shs = new ServiceHostManager<TService>();
                shs.Start();
                while (true)
                {
                    if (cancelTokenSource.IsCancellationRequested && shs != null)
                    {
                        shs.Stop();
                        break;
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex);
                if (shs != null)
                    shs.Stop();
            }
        }, cancelTokenSource.Token);

        return theTask;
    }
}

在Main方法中启动WCF主机

class Program
    {
        static Program()
        {
            Console.WriteLine("初始化...");
            Console.WriteLine("服务运行期间,请不要关闭窗口。");
            Console.WriteLine();
        }

        static void Main(string[] args)
        {
            Console.Title = "WCF主机 x64.(按 [Esc] 键停止服务)";
            var cancelTokenSource = new CancellationTokenSource();
            ServiceHostManager<WcfContract.Services.GameService>.StartNew(cancelTokenSource);
            ServiceHostManager<WcfContract.Services.PlayerService>.StartNew(cancelTokenSource);
            while (true)
            {
                if (Console.ReadKey().Key == ConsoleKey.Escape)
                {
                    Console.WriteLine();
                    cancelTokenSource.Cancel();
                    break;
                }
            }
            Console.ReadLine();
        }
    }

服务端配置

在控制台应用程序的App.config中配置system.serviceModel

<system.serviceModel>
    <services>
      <service name="Wettery.WcfContract.Services.GameService" behaviorConfiguration="gameMetadataBehavior">
        <endpoint address="net.tcp://localhost:19998/Wettery/GameService" binding="netTcpBinding" contract="Wettery.WcfContract.Services.IGameService" bindingConfiguration="netTcpBindingConfig">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
      </service>
      <service name="Wettery.WcfContract.Services.PlayerService" behaviorConfiguration="playerMetadataBehavior">
        <endpoint address="net.tcp://localhost:19998/Wettery/PlayerService" binding="netTcpBinding" contract="Wettery.WcfContract.Services.IPlayerService" bindingConfiguration="netTcpBindingConfig">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
      </service>
    </services>
    <bindings>
      <netTcpBinding>
        <binding name="netTcpBindingConfig" closeTimeout="00:30:00" openTimeout="00:30:00" receiveTimeout="00:30:00" sendTimeout="00:30:00" transactionFlow="false" transferMode="Buffered" transactionProtocol="OleTransactions" hostNameComparisonMode="StrongWildcard" listenBacklog="100" maxBufferPoolSize="2147483647" maxBufferSize="2147483647" maxConnections="100" maxReceivedMessageSize="2147483647">
          <readerQuotas maxDepth="64" maxStringContentLength="2147483647" maxArrayLength="2147483647 " maxBytesPerRead="4096" maxNameTableCharCount="16384" />
          <reliableSession ordered="true" inactivityTimeout="00:30:00" enabled="false" />
          <security mode="Transport">
            <transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" />
          </security>
        </binding>
      </netTcpBinding>
    </bindings>
    <behaviors>
      <serviceBehaviors>
        <behavior name="gameMetadataBehavior">
          <serviceMetadata httpGetEnabled="True" httpGetUrl="http://localhost:8081/Wettery/GameService/MetaData" />
          <serviceDebug includeExceptionDetailInFaults="True" />
          <serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000" />
        </behavior>
        <behavior name="playerMetadataBehavior">
          <serviceMetadata httpGetEnabled="True" httpGetUrl="http://localhost:8081/Wettery/PlayerService/MetaData" />
          <serviceDebug includeExceptionDetailInFaults="True" />
          <serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>

未避免元数据泄露,部署时将HttpGetEnable设为False

运行控制台应用程序

按[ESC]键终止服务

客户端测试

服务端运行后,用wcftestclient工具测试,服务地址即behavior中配置的元数据GET地址

http://localhost:8081/Wettery/GameService/MetaData
http://localhost:8081/Wettery/PlayerService/MetaData

时间: 2024-12-20 10:49:52

WCF绑定netTcpBinding寄宿到控制台应用程序的相关文章

WCF绑定netTcpBinding寄宿到IIS

继续沿用上一篇随笔中WCF服务类库 Wettery.WcfContract.Services WCF绑定netTcpBinding寄宿到控制台应用程序 服务端 添加WCF服务应用程序 Wettery.WcfIISHost.Services,其中添加两个WCF服务,GameService.svc  PlayerService.svc,删掉契约接口和 .cs内嵌文件,只留下.svc文件 我们通过Autofac注入契约/服务的依赖关系,Nuget引用 Install-Package Autofac.W

创建WCF服务自我寄宿

WCF服务的寄宿方式 WCF寄宿方式是一种非常灵活的操作,可以寄宿在各种进程之中,常见的寄宿有: IIS服务.Windows服务.Winform程序.控制台程序中进行寄宿,从而实现WCF服务的运行,为调用者方便.高效提供服务调用. 签名 前面介绍过了WCF常用的一种寄宿方式,IIS服务寄宿.这种寄宿方式是最为方便的方式,而且由于服务只需要IIS运行就能自动运行起来,因此广为使用. 创建这种方式IIS寄宿方式的,只需要在解决方案里面,添加WCF服务应用程序,就可以生成这种的服务模块了. 将WCF服

通过代码的方式完成WCF服务的寄宿工作

使用纯代码的方式进行服务寄宿 服务寄宿的目的是为了开启一个进程,为WCF服务提供一个运行的环境.通过为服务添加一个或者多个终结点,使之暴露给潜在的服务消费,服务消费者通过匹配的终结点对该服务进行调用,除去上面的两种寄宿方式,还可以以纯代码的方式实现服务的寄宿工作. 新建立一个控制台应用程序,添加System.ServiceModel库文件的引用. 添加WCF服务接口:ISchool使用ServiceContract进行接口约束,OperationContract进行行为约束 1 using Sy

WCF的WAS寄宿

这是一个测试的项目,最近突然想尝试一下把现有的WCF的wsHttpBinding换成netTcpBinding看看效率是否有点儿提高,各类网文都告诉我tcp的效率要好很多,也幸好有WAS寄宿,让我不用把现有的IIS的WCF服务迁移到Windows服务上去,记录一下过程中遇到的各类问题,仅供参考! 1.首先要把服务器环境搭好,我的服务器是Windows Server 2008 R2,控制面板->程序和功能->打开或关闭Windows功能,添加功能,把图示里的都勾上就可以了 2.上一步基本的教程里

WCF绑定类型选择

WCF绑定类型选择   发布日期:2010年12月10日星期五 作者:EricHu   在开发WCF程序时,如何选择一个适合的绑定对于消息传输的可靠性,传输模式是否跨进程.主机.网络,传输模式的支持.安全性.性能等方面有着重要的影响.而从本质上来看,绑定具有的这些特性源于其使用的网络协议和编码器.绑定是一个定制好的通道栈,包含了协议通道.传输通道和编码器.我们在开发WCF程序时,选择合适定是一个复杂的过程,没有万能的挑选公式可以套用.但是通常地,可以从是否需要交互特性.是否跨主机.是否需要脱机交

WCF绑定和行为在普通应用和SilverLight应用一些对比

本文版权归mephisto和博客园共有,欢迎转载,但须保留此段声明,并给出原文链接,谢谢合作. 阅读目录 介绍 绑定 行为 普通应用和SilverLight应用区别 本文版权归mephisto和博客园共有,欢迎转载,但须保留此段声明,并给出原文链接,谢谢合作. 介绍 WCF是构建和运行互联系统的一系列技术的总称,它是建立在Web Service架构上的一个全新的通信平台.我们可以把它看成是.NET平台上的新一代的Web Service.WCF的绑定和行为可以对提供的服务提供不同的通信方式支持和其

如何编写一个编译c#控制台应用程序的批处理程序

如何编写一个编译c#控制台应用程序的批处理程序 2011-03-22 18:14 dc毒蘑菇 | 浏览 579 次 最近在网上看了一个教程,是学C#的,但是我的机子上装不上vs,所以想写一个批处理来编译,因为每次都要我更改目录,然后复制路径,再编译,输出,特别的浪费时间,所以特来求助网友,希望帮帮忙 分享到: 2011-03-22 19:17 #快乐假期,智慧随行# 提问者采纳 不知道你有没有使用过ANT,你可以创建ANT脚本来构建你的应用程序.如果不是很了解,也不愿意编写的话,我介绍你一款可视

asp.net mvc引用控制台应用程序exe

起因:有一个控制台应用程序和一个web程序,web程序想使用exe程序的方法,这个时候就需要引用exe程序. 报错:使用web程序,引用exe程序 ,vs调试没有问题,但是部署到iis就报错,如下: 未能加载文件或程序集“Test.YiXiu”或它的某一个依赖项.试图加载格式不正确的程序. 处理办法: 修改控制台程序的输出方式,修改为[类库] 操作步骤: 在exe项目上右击=>属性=>输出类型,选择 类库

C#取得控制台应用程序的根目录方法

如有雷同,不胜荣幸,若转载,请注明 取得控制台应用程序的根目录方法1:Environment.CurrentDirectory 取得或设置当前工作目录的完整限定路径2:AppDomain.CurrentDomain.BaseDirectory 获取基目录,它由程序集冲突解决程序用来探测程序集 取得WinForm应用程序的根目录方法1:Environment.CurrentDirectory.ToString();//获取或设置当前工作目录的完全限定路径2:Application.StartupP