Recently, I worked on prototyping WCF load balancing for our product, FirstPoint. I built a simple example to test the configuration and behavior of load balancing. Since there aren't many end-to-end examples of WCF load balancing on the web, I'm hoping this will be useful (since the Microsoft documentation on this is basically non-existent...well, for NetTcpBindings at least).
I will assume that you are already familiar with network load balancing and configuring the NLB on Windows Server 2003.
Here's a screenshot of how I've configured my network load balancer:
You'll notice that I've configured a specific port range for my service. Also, take note of the cluster address: 192.168.1.220. The two servers that make up the cluster are FPDEV1 (192.168.1.222) and FPDEV2 (192.168.1.223).
I've defined a simple service interface which simply echoes the message with a server name:
using System.ServiceModel;
namespace WcfLoadBalancingSample.Server.Contracts {
/// <summary>
/// A simple service contract definition which defines an echo operation.
/// </summary>
[ServiceContract(SessionMode = SessionMode.Allowed)]
public interface IEchoService {
/// <summary>
/// Echoes the specified message.
/// </summary>
/// <param name="message">The message.</param>
/// <returns>The input message with a server identifier attached.</returns>
[OperationContract]
string Echo(string message);
}
}And here is the implementation:
using System;
using WcfLoadBalancingSample.Server.Contracts;
namespace WcfLoadBalancingSample.Server.Services {
/// <summary>
/// Implements the <c>IEchoService</c>.
/// </summary>
public class EchoService : IEchoService {
#region IEchoService Members
/// <summary>
/// Echoes the specified message.
/// </summary>
/// <param name="message">The message.</param>
/// <returns>
/// The input message with a server identifier attached.
/// </returns>
public string Echo(string message) {
return string.Format("[{0}] {1}", Environment.MachineName, message);
}
#endregion
}
} As you can see, I've simply prepended the machine name to each response so that we can track which server we are connecting to. Here is the main program which hosts the service:
using System;
using System.ServiceModel;
using WcfLoadBalancingSample.Server.Services;
namespace WcfLoadBalancingSample.Server {
internal class Program {
private static void Main(string[] args) {
var program = new Program();
program.Run();
}
public void Run() {
ServiceHost serviceHost = null;
try {
serviceHost = new ServiceHost(typeof (EchoService));
serviceHost.Open();
Console.Out.WriteLine("Service ready.");
Console.Out.WriteLine("Press any key to terminate.");
Console.Out.WriteLine("============================");
Console.ReadKey();
}
catch (Exception exception) {
Console.Out.WriteLine(exception);
Console.ReadKey();
}
finally {
if (serviceHost != null) {
serviceHost.Abort();
}
}
}
}
} This should be deployed on your each of your two (or more) servers in your cluster. The magic comes next in the configuration file:
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<services>
<service name="WcfLoadBalancingSample.Server.Services.EchoService"
behaviorConfiguration="WcfLoadBalancingSample.Server.Services.EchoServiceBehavior">
<!-- Service Endpoints -->
<!--///
The configured endpoint address is the IP address of the load balanced
cluster. The port number has been mapped to the cluster.
///-->
<endpoint
address ="net.tcp://192.168.1.220:12345/lb/EchoService"
binding="customBinding"
bindingConfiguration="DefaultCustomBinding"
contract="WcfLoadBalancingSample.Server.Contracts.IEchoService">
</endpoint>
</service>
</services>
<bindings>
<!--///
A simple custom binding. Note the leaseTimeout setting.
This is referenced in the SDK documentation, but not described
in any way as to how you're supposed to configure it.
///-->
<customBinding>
<binding name="DefaultCustomBinding">
<windowsStreamSecurity protectionLevel="None"/>
<binaryMessageEncoding/>
<tcpTransport>
<connectionPoolSettings leaseTimeout="00:00:01"/>
</tcpTransport>
</binding>
</customBinding>
</bindings>
<behaviors>
<serviceBehaviors>
<behavior name="WcfLoadBalancingSample.Server.Services.EchoServiceBehavior">
<serviceMetadata httpGetEnabled="True"
httpGetUrl="http://192.168.1.220/lb/EchoService/MEX"/>
<serviceDebug includeExceptionDetailInFaults="True" />
</behavior>
</serviceBehaviors>
</behaviors>
</system.serviceModel>
</configuration>The most important part of this configuration file is the setting for the lease timeout. The SDK documentation references this setting, but does not go into detail on how it's configured. Note that it seems that you can only set the least timeout value in configuration using a custom binding.
There is one particularly important thing to note here: I've set the timeout to 1 second for demonstration purposes only. The SDK documentation mentions that this value should be set to 30 seconds. As we'll see later, I have the client creating a new connection every 2.5 seconds (on purpose so we can test connectivity). What I found was that with the default setting (5 minutes, according to the SDK), if you initially connect to server A and server A goes down, it will not automatically connect to server B. I assume this is because of the lease timeout value (it throws an exception).
Also note that the endpoint is configured using the IP address of the node balancing cluster and not the individual servers.
The client side of it is pretty straight forward as well:
using System;
using System.Runtime.Remoting.Messaging;
using System.Threading;
using WcfLoadBalancingSample.Client.LoadBalancedService;
namespace WcfLoadBalancingSample.Client {
public delegate void EchoDelegate();
public class EchoEventArgs : EventArgs {
public EchoEventArgs(string message) {
Message = message;
}
public string Message { get; set; }
}
internal class Program {
private static void Main(string[] args) {
var program = new Program();
program.Run();
}
public void Run() {
// Start the server.
Console.Out.WriteLine("Starting client...(press any key to exit)");
// Start second thread to ping the server.
EchoDelegate echoDelegate = EchoAsync;
echoDelegate.BeginInvoke(EchoAsycCompleted, null);
Console.Read();
}
/// <summary>
/// Asynchronous execution of the call to the server.
/// </summary>
private void EchoAsync() {
try {
int count = 0;
while (true) {
using (var serviceClient = new EchoServiceClient()) {
// Call the echo service.
string result = serviceClient.Echo(
count.ToString());
Console.Out.WriteLine(result);
count++;
}
Thread.Sleep(2500);
}
}
catch (Exception exception) {
Console.Out.WriteLine(exception);
}
}
/// <summary>
/// Handles the completion of the thread.
/// </summary>
/// <param name="result">The result.</param>
private void EchoAsycCompleted(IAsyncResult result) {
var r = (AsyncResult) result;
var e = (EchoDelegate) r.AsyncDelegate;
e.EndInvoke(r);
}
}
}The only thing to note is that I used a delegate to spin off a second thread to make the call to the server. Adding a reference to the server generates the following configuration file:
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<bindings>
<netTcpBinding>
<binding name="CustomBinding_IEchoService">
<security mode="Transport">
<transport clientCredentialType="Windows"
protectionLevel="None" />
<message clientCredentialType="Windows" />
</security>
</binding>
</netTcpBinding>
</bindings>
<client>
<endpoint
address="net.tcp://192.168.1.220:12345/lb/EchoService"
binding="netTcpBinding"
bindingConfiguration="CustomBinding_IEchoService"
contract="LoadBalancedService.IEchoService"
name="CustomBinding_IEchoService">
<identity>
<userPrincipalName value="Administrator@fpdev.com" />
<servicePrincipalName value="" />
<dns value="192.168.1.220" />
</identity>
</endpoint>
</client>
</system.serviceModel>
</configuration>Note that on this side, the binding is generated as a netTcpBinding.
And that's it! Deploy the service to your clustered servers and start the services and then start the client. If your cluster has a bias towards one server, you will see that the messages will come from that server. To test that it actually is load balancing, simply stop the service on that server and you should see that the output will be coming from the other server. Here's an example:
You can see that after I stop the service on FPDEV1 at the third echo message, it flips over to FPDEV2! Awesome!
Here's the full project (VS2008): WcfLoadBalancingSample.zip (16.89 KB)