WCF 第四章 绑定 netMsmqBinding

MSMQ 为使用队列创建分布式应用程序提供支持。WCF支持将MSMQ队列作为netMsmqBinding绑定的底层传输协议的通信。 netMsmqBinding绑定允许客户端直接把消息提交到一个队列中同时服务端从队列中读取消息。客户端和服务端之间没有直接通信过程；因此，通信本 质是断开的。也意外着所有的通信必须是单向的。因此，所有的操作必须要在操作契约上设置IsOneWay=true属性。

提示 动态创建队列

使用netMsmqBinding时动态创建MSMQ队列是很普通的。当创建一个离线客户端应用而且队列在一个用户的桌面时使用netMsmqBinding绑定更加平常。这可以通过创建System.MessageQueue类的静态方法来实现。

下面的代码显示了netMsmqBinding绑定的地址格式:

  net.msmq:{hostname}/[private/|[public/]]{query name}

  MSMQ默认端口是1801而且没有配置解决方案。注意地址格式中的public和private.你可以显式的确定是否队列名字指向一个私有的或者公有的队列。默认情况下，队列名字假设指向一个公共队列。

表4.11 netMsmqBinding 绑定属性

 

  我们在列表4.2到4.4使用的StockQuoteService样例程序需要被修改以便于与netMsmqBinding绑定一起工作。 netMsmqBinding绑定仅支持单向操作(查看表4.2).我们之前的操作契约使用一个请求回复消息交换模式(查看列表4.4).我们将修改 StockQuoteService例子来显示基于netMsmqBinding绑定的双向通信而不是显示一个不同的例子。

  我们需要使用两个单向操作契约来维护服务端和客户端的双向通信。这意味着我们需要重新定义我们的契约以便于使用netMsmqBinding绑 定。列表4.24显示了写来与netMsmqBinding绑定一起使用的stock quote 契约。首先，注意我们把请求和回复契约转换成两个独立的服务契约：IStockQuoteRequest和IStockQuoteResponse.每个 契约上的操作都是单向的。IStockQuoteRequest契约将被客户端用来向服务端发送消息。IStockQuoteResponse契约将被服 务端用来发送一条消息给客户端。这意味着客户端和服务端都将寄宿服务来接收消息。

列表 4.24 IStockQuoteRequest，IStockQuoteResponse和StockQuoteRequestService

01using System;
02using System.Collections.Generic;
03using System.Linq;
04using System.Text;
05using System.ServiceModel;
06using System.Transactions;
07 
08namespace EssentialWCF
09{
10    [ServiceContract]
11    public interface IStockQuoteRequest
12    {
13        [OperationContract(IsOneWay=true)]
14        void SendQuoteRequest(string symbol);
15    }
16 
17    [ServiceContract]
18    public interface IStockQuoteResponse
19    {
20        [OperationContract(IsOneWay = true)]
21        void SendQuoteResponse(string symbol, double price);
22    }
23 
24    public class StockQuoteRequestService : IStockQuoteRequest
25    {
26        public void SendQuoteRequest(string symbol)
27        {
28            double value;
29            if (symbol == "MSFT")
30                value = 31.15;
31            else if (symbol == "YHOO")
32                value = 28.10;
33            else if (symbol == "GOOG")
34                value = 450.75;
35            else
36                value = double.NaN;
37 
38            //Send response back to client over separate queue
39            NetMsmqBinding msmqResponseBinding = new NetMsmqBinding();
40            using (ChannelFactory<IStockQuoteResponse> cf = new ChannelFactory<IStockQuoteResponse>("NetMsmqResponseClient"))
41            {
42                IStockQuoteResponse client = cf.CreateChannel();
43                using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
44                {
45                    client.SendQuoteResponse(symbol, value);
46                    scope.Complete();
47                }
48                cf.Close();
49            }
50        }
51    }
52}

   netMsmqBinding下一个要考虑的就是使用ServiceHost类。先前的例子可以在不同的绑定上重用相同的ServiceHost代码。这 因为服务契约可以保持一样。而不是因为使用了netMsmqBinding。更新的用来寄宿StockServiceRequestService服务的 ServiceHost代码在列表4.25中显示。我们已经更新代码来动态创建一个在基于配置文件中queueName的MSMQ队列。这有助于通过简单 配置允许程序部署而不需要额外的MSMQ配置。

列表 4.25 StockQuoteRequestService ServiceHost 服务

01using System;
02using System.Collections.Generic;
03using System.Linq;
04using System.Text;
05using System.ServiceModel;
06using System.Configuration;
07using System.Messaging;
08 
09namespace EssentialWCF
10{
11    class Program
12    {
13        static void Main(string[] args)
14        {
15            MyServiceHost.StartService();
16            Console.WriteLine("Service is Started, press Enter to terminate.");
17            Console.ReadLine();
18            MyServiceHost.StopService();
19        }
20    }
21 
22    internal class MyServiceHost
23    {
24        internal static string queryName = string.Empty;
25        internal static ServiceHost myServiceHost = null;
26 
27        internal static void StartService()
28        {
29            queryName = ConfigurationManager.AppSettings["queueName"];
30            if (!MessageQueue.Exists(queryName))
31                MessageQueue.Create(queryName, true);
32            myServiceHost = new ServiceHost(typeof(EssentialWCF.StockQuoteRequestService));
33            myServiceHost.Open();
34        }
35        internal static void StopService()
36        {
37            if (myServiceHost.State != CommunicationState.Closed)
38                myServiceHost.Close();
39        }
40    }
41}

   列表4.26的配置信息使用netMsmqBinding绑定暴露StockQuoteRequestService服务。它也为IStockQuoteResponse契约配置一个客户端终结点以便于回复可以发送给客户端。

列表 4.26 netMsmqBinding 宿主 配置

01<?xml version="1.0" encoding="utf-8" ?>
02<configuration>
03    <system.serviceModel>
04        <client>
05            <endpoint address="net.msmq://localhost/private/stockquoteresponse"
06                binding="netMsmqBinding" bindingConfiguration="NoMsmqSecurity"
07                contract="EssentialWCF.IStockQuoteResponse" name="NetMsmqResponseClient" />
08        </client>
09        <bindings>
10            <netMsmqBinding>
11                <binding name="NoMsmqSecurity">
12                    <security mode="None" />
13                </binding>
14            </netMsmqBinding>
15        </bindings>
16        <services>
17            <service name="EssentialWCF.StockQuoteRequestService">
18                <endpoint address="net.msmq://localhost/private/stockquoterequest"
19                    binding="netMsmqBinding" bindingConfiguration="NoMsmqSecurity"
20                    name="" contract="EssentialWCF.IStockQuoteRequest" />
21            </service>
22        </services>
23    </system.serviceModel>
24  <appSettings>
25    <add key="queueName" value=".\private$\stockquoterequest"/>
26  </appSettings>
27</configuration>

  客户端应用程序必须使用netMsmqBinding寄宿一个服务来接受回复且配置一个终结点来发送请求给服务端。列表4.27 显示了客户端用来寄宿一个实现了IStockQuoteResponse契约的ServiceHost类。我们添加代码来动态创建一个客户端监听的队列。 再次，这有助于通过简单配置允许程序部署而不需要额外的MSMQ配置。

列表 4.27 StockQuoteResponseService ServiceHost 客户端

01using System;
02using System.Collections.Generic;
03using System.Linq;
04using System.Text;
05using System.ServiceModel;
06using System.Configuration;
07using System.Messaging;
08 
09namespace EssentialWCF
10{
11    internal class MyServiceHost
12    {
13        internal static ServiceHost myServiceHost = null;
14 
15        internal static void StartService()
16        {
17            string queryName = ConfigurationManager.AppSettings["queueName"];
18            if (!MessageQueue.Exists(queryName))
19                MessageQueue.Create(queryName, true);
20            myServiceHost = new ServiceHost(typeof(EssentialWCF.Program));
21            myServiceHost.Open();
22        }
23        internal static void StopService()
24        {
25            if (myServiceHost.State != CommunicationState.Closed)
26                myServiceHost.Close();
27        }
28    }
29}

   列表4.28 显示了IStockQuoteResponse接口的客户端实现。客户端实现了接口，接下来被服务端当作发送回复的回调端。这不是使用了WCF中的双向能力。相反的，回调使用一个单独的单向绑定实现。

01using System;
02using System.Collections.Generic;
03using System.Linq;
04using System.Text;
05using System.Threading;
06using System.ServiceModel;
07using System.Transactions;
08 
09namespace EssentialWCF
10{
11    public class Program : IStockQuoteResponse
12    {
13        private static AutoResetEvent waitForResponse;
14        static void Main(string[] args)
15        {
16            //Start response service host
17            MyServiceHost.StartService();
18            try
19            {
20                waitForResponse = new AutoResetEvent(false);
21                //Send request to the server
22                using (ChannelFactory<IStockQuoteRequest> cf = new ChannelFactory<IStockQuoteRequest>("NetMsmqRequestClient"))
23                {
24                    IStockQuoteRequest client = cf.CreateChannel();
25                    using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
26                    {
27                        client.SendQuoteRequest("MSFT");
28                        scope.Complete();
29                    }
30                    cf.Close();
31                }
32                waitForResponse.WaitOne();
33            }
34            finally
35            {
36                MyServiceHost.StopService();
37            }
38            Console.ReadLine();
39        }
40 
41        public void SendQuoteResponse(string symbol, double price)
42        {
43            Console.WriteLine("{0}@${1}", symbol, price);
44            waitForResponse.Set();
45        }
46    }
47}

   让netMsmqBinding Stock Quote 样例工作起来的最后一步是客户端配置文件。列表4.29 显示了客户端配置，包含了寄宿IStockQuoteResponse服务实现的信息，调用IStockQuoteRequest服务的终结点配置。

列表 4.29 netMsmqBinding 客户端配置

view sourceprint?
01<?xml version="1.0" encoding="utf-8" ?>
02<configuration>
03    <system.serviceModel>
04        <bindings>
05            <netMsmqBinding>
06                <binding name="NoMsmqSecurity">
07                    <security mode="None" />
08                </binding>
09            </netMsmqBinding>
10        </bindings>
11        <client>
12            <endpoint address="net.msmq://localhost/private/stockquoterequest"
13                binding="netMsmqBinding" bindingConfiguration="NoMsmqSecurity"
14                contract="EssentialWCF.IStockQuoteRequest" name="NetMsmqRequestClient" />
15        </client>
16        <services>
17            <service name="EssentialWCF.StockQuoteRequestService">
18                <endpoint address="net.msmq://localhost/private/stockquoteresponse"
19                    binding="netMsmqBinding" bindingConfiguration="NoMsmqSecurity"
20                    contract="EssentialWCF.IStockQuoteResponse" />
21            </service>
22        </services>
23    </system.serviceModel>
24  <appSettings>
25    <add key="queueName" value=".\private$\stockquoteresponse"/>
26  </appSettings>
27</configuration>


===========

转载自

作者：DanielWise
出处：http://www.cnblogs.com/danielWise/
 

转载于:https://www.cnblogs.com/llbofchina/archive/2011/06/29/2093025.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/274845.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

React 18 RC 版本发布啦，生产环境用起来！

React 18 RC 版本发布啦，生产环境用起来！

大家好&#xff0c;我是若川。持续组织了6个月源码共读活动&#xff0c;感兴趣的可以点此加我微信 ruochuan12 参与&#xff0c;每周大家一起学习200行左右的源码&#xff0c;共同进步。同时极力推荐订阅我写的《学习源码整体架构系列》 包含20余篇源码文章。历史面试系列今天给…
阅读更多...
阿拉伯语排版设计_针对说阿拉伯语的用户的测试和设计

阿拉伯语排版设计_针对说阿拉伯语的用户的测试和设计

阿拉伯语排版设计Let me start off with some data to put things into perspective “Why?”让我从一些数据入手&#xff0c;以透视“为什么&#xff1f;”的观点。 Arabic is the 5th most spoken language worldwide, with 420 million speakers, and is an official lang…
阅读更多...
CMMI简介

CMMI简介

CMMI&#xff08;Capability Maturity Model Integration&#xff09;即能力成熟度模型集成 什么是CMMI CMMI是CMM模型的最新版本。早期的CMMI&#xff08;CMMI-SE/SW/IPPD&#xff09;1.02版本是应用于软件业项目的管理方法&#xff0c;SEI在部分国家和地区开始推广和试用。随…
阅读更多...
SVN：“SVN”不是内部命令，解决方法

SVN：“SVN”不是内部命令，解决方法

1、安装完TortoiseSVN-1.6.16.21511-x64-svn-1.6.17.msi 2、在运行窗口cmd---svn&#xff0c;提示&#xff1a; “SVN” 不是内部命令 郁闷&#xff0c;小有纠结 解决方法&#xff1a;安装Slik-Subversion-1.6.17-x64.msi 命令行窗口关闭&#xff0c;再次打开命令行窗口&#x…
阅读更多...
7个月，4000+人，500+源码笔记，诚邀你参加源码共读~

7个月，4000+人，500+源码笔记，诚邀你参加源码共读~

大家好&#xff0c;我是若川。按照从易到难的顺序&#xff0c;前面几期&#xff08;比如&#xff1a;validate-npm-package-name、axios工具函数&#xff09;很多都只需要花2-3小时就能看完&#xff0c;并写好笔记。但收获确实很大。开阔视野、查漏补缺、升职加薪。已经有400笔…
阅读更多...
火焰和烟雾的训练图像数据集_游戏开发者是烟雾和镜子的大师

火焰和烟雾的训练图像数据集_游戏开发者是烟雾和镜子的大师

火焰和烟雾的训练图像数据集Video games are incredible. They transport us to new worlds, allow us to partake in otherwise impossible situations, and empower us in our every day lives. Games can make us feel like a part of something bigger than ourselves, per…
阅读更多...
平衡树SPLAY

平衡树SPLAY

一个比线段树代码还要又臭又长的数据结构&#xff0c;各式各样的函数&#xff0c;咱也不知道别人怎么记住的&#xff0c;咱也不敢问 SPLAY的性质 1.某个节点的左子树全部小于此节点&#xff0c;右子树全部大于此节点 2.中序遍历splay输出的序列是按从小到大的顺序 &#xff08;…
阅读更多...
POJ 2696 计算表达式的值

POJ 2696 计算表达式的值

时间限制: 1000ms内存限制:65536kB描述有些语言中表达式的运算符使用字符串表示&#xff0c;例如用mul代表*&#xff0c;用div代表/&#xff0c;用add代表&#xff0c;用sub代表-&#xff0c;用mod代表%。输入第一行为表达式的个数n。其余n行每行一个表达式&#xff0c;表达式由…
阅读更多...
为支持两个语言版本，我基于谷歌翻译API写了一款自动翻译的 webpack 插件

为支持两个语言版本，我基于谷歌翻译API写了一款自动翻译的 webpack 插件

大家好&#xff0c;我是若川。持续组织了6个月源码共读活动&#xff0c;感兴趣的可以点此加我微信 ruochuan12 参与&#xff0c;每周大家一起学习200行左右的源码&#xff0c;共同进步。同时极力推荐订阅我写的《学习源码整体架构系列》 包含20余篇源码文章。历史面试系列本文来…
阅读更多...
全球 化 化_全球化设计

全球 化 化_全球化设计

全球 化 化重点 (Top highlight)Designing for a global audience can feel daunting. Do you localize your product? Or, do you internationalize your product? And what does that even entail?为全球观众设计可能会令人生畏。 您是否将产品本地化&#xff1f; 还是您将…
阅读更多...
springMVC_数据的处理过程

springMVC_数据的处理过程

1、DispatcherServlet&#xff1a;作为前端控制器&#xff0c;负责分发客户的请求到 Controller 其在web.xml中的配置如下&#xff1a; <servlet><servlet-name>dispatcherServlert</servlet-name><servlet-class>org.springframework.web.servlet.Dis…
阅读更多...
面试体验：Facebook 篇（转）

面试体验：Facebook 篇（转）

http://www.cnblogs.com/cathsfz/archive/2012/11/05/facebook-interview-experience.html 2012-11-05 08:20 by Cat Chen, 23266阅读, 121评论, 收藏, 编辑 Google、Microsoft 和 Yahoo 都是去年的事情了&#xff0c;接下来说说今年…
阅读更多...
JavaScript 新增两个原始数据类型

JavaScript 新增两个原始数据类型

大家好&#xff0c;我是若川。持续组织了6个月源码共读活动&#xff0c;感兴趣的可以点此加我微信 ruochuan12 参与&#xff0c;每周大家一起学习200行左右的源码&#xff0c;共同进步。同时极力推荐订阅我写的《学习源码整体架构系列》 包含20余篇源码文章。历史面试系列JavaS…
阅读更多...
axure低保真原型_如何在Google表格中创建低保真原型

axure低保真原型_如何在Google表格中创建低保真原型

axure低保真原型Google Sheets is a spreadsheet, just like Microsoft Excel.Google表格是一个电子表格&#xff0c;就像Microsoft Excel一样。 Most people associate it with calculating numbers. But Google Sheets is actually great for organizing your ideas, making…
阅读更多...
Weblogic EJB 学习笔记(3)精

Weblogic EJB 学习笔记(3)精

编辑实体bean的高级课程 1. 怎样开发主健类 ejb的主健类主要用做持久存储和ejb容器中的唯一标识符. 通常主健类的字段直接映射到数据库中的主健字段. 如果主健只是由单个实体bean字段组成.且其数据类型是基本的java类.如string,则bean作者不必开发自定义的主健类. 只需要在配置…
阅读更多...
Lerna 运行流程剖析

Lerna 运行流程剖析

大家好&#xff0c;我是若川。持续组织了6个月源码共读活动&#xff0c;感兴趣的可以点此加我微信 ruochuan12 参与&#xff0c;每周大家一起学习200行左右的源码&#xff0c;共同进步。同时极力推荐订阅我写的《学习源码整体架构系列》 包含20余篇源码文章。历史面试系列Lerna…
阅读更多...
手动创建线程池 效果会更好_创建更好的，可访问的焦点效果

手动创建线程池 效果会更好_创建更好的，可访问的焦点效果

手动创建线程池 效果会更好Most browsers has their own default, outline style for the :focus psuedo-class.大多数浏览器对于&#xff1a;focus psuedo-class具有其默认的轮廓样式。 Chrome’s default outline styleChrome浏览器的默认轮廓样式 This outline style is cr…
阅读更多...
C++builder enum类型

C++builder enum类型

C/C code #pragmaoption push -b-enumTThreadPriority { tpIdle, tpLowest, tpLower, tpNormal, tpHigher, tpHighest, tpTimeCritical }; //这是字节型的.理论上说这是可能的最小整形.可以是1Byte, 2Bytes, 4Bytes...#pragmaoption pop#pragmaoption push -benumTThreadPriori…
阅读更多...
chrome浏览器世界之窗浏览器的收藏夹在哪？

chrome浏览器世界之窗浏览器的收藏夹在哪？

今天心血来潮&#xff0c;用一个查重软件删除重复文件&#xff0c;结果把chrome浏览器和世界之窗浏览器的收藏夹给删除了&#xff0c;导致我保存的好多网页都没有了&#xff0c;在浏览器本身和网上都没有找到这两个浏览器默认的收藏夹在哪个位置&#xff0c;只好用DiskGenius 把…
阅读更多...
Vue3究竟好在哪里 等推荐

Vue3究竟好在哪里 等推荐

话不多说&#xff0c;这一次花了几小时精心为大家挑选了30余篇好文&#xff0c;供大家阅读学习&#xff0c;提升自己的技术视野以及扩展自己的知识储备。本文阅读技巧&#xff0c;先粗看标题&#xff0c;感兴趣可以都关注一波&#xff0c;一起共同进步。前端从进阶到入院框架原…
阅读更多...
最新文章

Copyright @ 2022~2023