【IT168微软云计算博客征文活动专稿】本文将向大家介绍如何托管内部WCF服务和公共WCF服务，为了托管内部WCF服务，需要建立一个内部端点，并使用内部角色通信，与在输入端点上托管一个外部服务最主要的区别是内部端点不具有负载均衡特性，而输入端点是挂钩在负载均衡器上的，具有负载均衡功能。
托管内部WCF服务
其实要托管一个内部WCF服务很简单，唯一需要注意的是传递给 ServiceHost 的基地址不同，因为端口号和IP地址要等到运行时才知道，因此需要创建一个主机，动态地传递这些信息给它。
public override bool OnStart()
{
// 设置最大并发连接数
ServicePointManager.DefaultConnectionLimit = 12;
DiagnosticMonitor.Start("DiagnosticsConnectionString");
// For information on handling configuration changes
// see the MSDN topic at http://go.microsoft.com/fwlink/?LinkId=166357.
RoleEnvironment.Changing += RoleEnvironmentChanging;
StartWCFService();
return base.OnStart();
}
private void StartWCFService()
{
var baseAddress = String.Format(
"net.tcp://{0}",
RoleEnvironment.CurrentRoleInstance.InstanceEndpoints["EchoService"].IPEndpoint
);
var host = new ServiceHost(typeof(EchoService), new Uri(baseAddress));
host.AddServiceEndpoint(typeof(IEchoService), new NetTcpBinding(SecurityMode.None), "echo");
host.Open();
{
// 设置最大并发连接数
ServicePointManager.DefaultConnectionLimit = 12;
DiagnosticMonitor.Start("DiagnosticsConnectionString");
// For information on handling configuration changes
// see the MSDN topic at http://go.microsoft.com/fwlink/?LinkId=166357.
RoleEnvironment.Changing += RoleEnvironmentChanging;
StartWCFService();
return base.OnStart();
}
private void StartWCFService()
{
var baseAddress = String.Format(
"net.tcp://{0}",
RoleEnvironment.CurrentRoleInstance.InstanceEndpoints["EchoService"].IPEndpoint
);
var host = new ServiceHost(typeof(EchoService), new Uri(baseAddress));
host.AddServiceEndpoint(typeof(IEchoService), new NetTcpBinding(SecurityMode.None), "echo");
host.Open();
使用内部WCF服务
我想从我另一个托管的服务调用这个服务，下面就是调用这个服务的所有代码：
protected void Button1_Click(object sender, EventArgs e)
{
var factory = new ChannelFactory<WorkerHost.IEchoService>(new NetTcpBinding(SecurityMode.None));
var channel = factory.CreateChannel(GetRandomEndpoint());
Label1.Text = channel.Echo(TextBox1.Text);
}
private EndpointAddress GetRandomEndpoint()
{
var endpoints = RoleEnvironment.Roles["WorkerHost"].Instances
.Select(i => i.InstanceEndpoints["EchoService"])
.ToArray();
var r = new Random(DateTime.Now.Millisecond);
return new EndpointAddress(
String.Format(
"net.tcp://{0}/echo",
endpoints[r.Next(endpoints.Count() - 1)].IPEndpoint)
);
}
{
var factory = new ChannelFactory<WorkerHost.IEchoService>(new NetTcpBinding(SecurityMode.None));
var channel = factory.CreateChannel(GetRandomEndpoint());
Label1.Text = channel.Echo(TextBox1.Text);
}
private EndpointAddress GetRandomEndpoint()
{
var endpoints = RoleEnvironment.Roles["WorkerHost"].Instances
.Select(i => i.InstanceEndpoints["EchoService"])
.ToArray();
var r = new Random(DateTime.Now.Millisecond);
return new EndpointAddress(
String.Format(
"net.tcp://{0}/echo",
endpoints[r.Next(endpoints.Count() - 1)].IPEndpoint)
);
}
这里唯一要注意的是查询F abric ，确定 WorkerHost 角色中实现了 EchoService 端点，并随机给它们路由请求的所有端点，本来不需要路由请求，我这样做是因为内部端点没有负载均衡功能，我希望在每个 WorkerHost 实例上均匀地分配负载。
我发现一个技巧，就是不需要缓存你找到的 IPEndpoint ，因为它已经缓存在API调用中，但根据非常好的实践，你应该缓存你的 ChannelFactory 。
托管公共WCF服务
托管公共WCF服务也很简单，唯一需要注意的是要使用一个新的行为，为MEX端点处理负载均衡，此外，在你的服务上需要包括一个类属性处理地址过滤不匹配问题。
