实战WCF中net.tcp和net.msmq绑定协议

平时很少写博文的，以前都是转载其他园友的文章，这几天有时间就自己尝试写一些wcf相关的文章，希望能给有需要的人带来一点帮助吧，水平有限再加上初次动手，写得不好还请多多包含！废话不多说了直接进入正题。

1.首先是项目结构（截图）命名不是很规范——仅自己练手用的

注意：WcfInterface是wcf的服务接口

        ProductService是wcf的服务的实现

        ProductSVCWebApp服务webapp

         productservice.svc通过net.tcp绑定协议对外发布服务

         messageservice.svc通过net.msmq绑定协议对外发布服务

              主要是通过web.config中的servicemodel配置节点实现，该节点中主要分为3部分完全可通过手工配置：bindings绑定、behaviors行为、services服务配置对外发布的服务终结点endpoint——详情请见以下代码

        ServiceModel是相关的数据契约

一、wcfinterface项目是独立的服务契约

1.IMessage服务接口

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.ServiceModel;
using ServiceModel;

namespace WcfInterface
{
    [ServiceContract]
    public interface IMessage
    {
        [OperationContract(IsOneWay=true)]
        void Send(Message log);
    }
}

2.IServiceTest服务接口

using ServiceModel;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;

namespace WcfInterface
{
    [ServiceContract]
    public interface IServiceTest
    {
        [OperationContract]
        int AddProduct(Product product);

        [OperationContract]
        Product GetProductById(int Id);

    }
}

二、ProductService类库

1.IMessage的服务实现

using ServiceModel;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WcfInterface;

namespace ProductService
{
    public class MsmqServiceTest:IMessage
    {
        private static IList<Message> list = new List<Message>();

        public void Send(ServiceModel.Message log)
        {
            list.Add(log);
        }
    }
}

2.IServiceTest服务

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WcfInterface;
using ServiceModel;


namespace ProductService
{
    public class ProductImpl : IServiceTest
    {
        private static  IList<Product> list = new List<Product>();
        public int AddProduct(Product product)
        {
            list.Add(product);
            return 1;
        }

        public Product GetProductById(int Id)
        {
            return list.FirstOrDefault(p => p.Id.Equals(Id));
        }


    }
}

三、数据契约类库ServiceModel

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.Text;
using System.Threading.Tasks;

namespace ServiceModel
{
    [DataContract]
    public class Product
    {
        [DataMember]
        public int Id { get; set; }
        [DataMember]
        public string Name { get; set; }
        [DataMember]
        public decimal Cost { get; set; }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Runtime.Serialization;

namespace ServiceModel
{
    [DataContract]
   public class Message
    {
        [DataMember]
       public int Id { get; set; }
       
        [DataMember]
        public string Header { get; set; }

       [DataMember]
        public string Body { get; set; }
    }
}

四、ProductSVCWebapp

productservice.svc服务文件

<%@ ServiceHost Language="C#" Debug="true" Service="ProductService.MsmqServiceTest" %>

messageservice.svc服务文件

<%@ ServiceHost Language="C#" Debug="true" Service="ProductService.MsmqServiceTest" %>

web.config中servicemodel配置

<system.serviceModel>
    <services>
      <service behaviorConfiguration="endpointbinding" name="ProductService.ProductImpl">
        <endpoint address="net.tcp://localhost/ProductService/ProductService.svc" binding="netTcpBinding" bindingConfiguration="tcpbindingtest" name="netTcpBinding_IServiceTest" contract="WcfInterface.IServiceTest"></endpoint>
      </service>
      <service name="ProductService.MsmqServiceTest">
        <endpoint address="net.msmq://localhost/private/ProductService/ProductService.svc" binding="netMsmqBinding" contract="WcfInterface.IMessage" bindingConfiguration="msmqbindingtest" name="netMsmqBinding_IMessage"></endpoint>
      </service>
    </services>
    <bindings>
      <netMsmqBinding>
        <binding name="msmqbindingtest" exactlyOnce="false">
          <security>
            <transport msmqProtectionLevel="None" msmqAuthenticationMode="None"/>
            <message clientCredentialType="None"/>
          </security>
        </binding>
      </netMsmqBinding>
      <netTcpBinding>
        <binding name="tcpbindingtest">
          <security mode="None">
            <transport protectionLevel="None" clientCredentialType="None"></transport>
            <message clientCredentialType="None" />
          </security>
        </binding>
      </netTcpBinding>
    </bindings>
    <behaviors>
      <serviceBehaviors>
        <behavior name="endpointbinding">
          <serviceMetadata httpGetEnabled="true" httpsGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="false" />
        </behavior>
        <behavior name="">
          <serviceMetadata httpGetEnabled="true" httpsGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="false" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
    <serviceHostingEnvironment aspNetCompatibilityEnabled="true"
      multipleSiteBindingsEnabled="true" />
  </system.serviceModel>

由于我这里用到msmq，建立私有的消息队列名字和address="net.msmq://localhost/private/ProductService/ProductService.svc"里的名字对应起来

五、部署——IIS承载服务及iis中相关配置

服务app以及web站点都需要启用协议net.msmq/net.tcp,另外服务还需要添加msmq和tcp的绑定

我的iis配置ProductService服务建立在defaultweb site下默认的defaultweb site已经添加了net.tcp和net.msmq，http绑定等

testwcf部署web站点

服务运行截图：

本人QQ：443813032 如有不妥之处，还请指正，互相学习，共同进步！！！近期研究go lang中，go将超过java,c成为未来10年最流行的语言，有人说它是20世纪的c语言！希望更多的人加入，一起将go发扬光大！！！