【发布时间】：2011-09-12 11:51:03
【问题描述】：
我有问题。我编写了一个使用 wsHttpBinding 的 wcf 客户端（WPF 和 c#）。 我正在使用双工。我有一个功能，我每分钟调用一次 wcf 服务，称为 KeepConnection。 而且我从不关闭客户端代理，因为我需要让客户端始终“在线”以进行服务回调。但是当在 Windows XP 上运行这个客户端时，我的应用程序的内存出现了一个奇怪的问题。在 win 7 /vista 上正常运行时，应用程序在任务管理器中只使用了 40mb 的内存。在Xp中每秒不断地增加内存的使用。 我在 2 天内获得了超过 700mb。
有没有办法解决这个问题，或者它与 XP 相关。感谢您的帮助。
服务代码：
/// <summary>
/// Just an empty method for client to keep the connection alive with the service.
/// </summary>
public void KeepConnection()
{
_logger.Debug("Keep alive requested.");
}
我的客户代码。
private InstanceContext instanceContext; //Wcf instance context for callbacks.
public static BootDialog _bootScreen = new BootDialog(); //Boot window.
public static RetryDialog _retryScreen = new RetryDialog(); //Retry window.
public static ProductionServiceClient service; //Wcf service client
public static ClientCallBack clientBack; //Client callback events and handler.
public static ClientTokenResponse ClientToken; //ClientToken from wcf service.
public static int[] ScannerNumbers;
public static IList<HighlightArticleDto> highListArticleList; //List and color of witch list to highligt.
private static readonly Logger _logger = LogManager.GetCurrentClassLogger();
private static ClientTokenRequest clientRequest;
private Timer _keepAliveTimer = new Timer();
private void Application_Startup(object sender, StartupEventArgs e)
{
_logger.Trace("Enter Application_Startup().");
int[] scannerNumberList = ParseHandler.GetScannersFromSettingString(Settings.Default.Scanners);
//Saves it globally
App.ScannerNumbers = scannerNumberList;
_logger.Info("Getting {0} scanners for this client.", scannerNumberList.Count());
clientBack = new ClientCallBack();
instanceContext = new InstanceContext(clientBack);
//ToDO : This fix is for XP computer with the http://+:80/Temporary_Listen_Addresses/c269764e-808e-4284-ad7f-4e0eb88ee951/ error.
WSDualHttpBinding binding = new WSDualHttpBinding();
binding.Name = "WsDualTcpEndpoint";
binding.CloseTimeout = new TimeSpan(0, 0, 10);
binding.OpenTimeout = new TimeSpan(0, 0, 10);
//binding.ReceiveTimeout = new TimeSpan(0, 0, 30);
binding.SendTimeout = new TimeSpan(0, 0, 10);
binding.BypassProxyOnLocal = false;
binding.TransactionFlow = false;
binding.HostNameComparisonMode = HostNameComparisonMode.StrongWildcard;
binding.MaxBufferPoolSize = 524288;
binding.MaxReceivedMessageSize = 65536;
binding.MessageEncoding = WSMessageEncoding.Text;
binding.TextEncoding = System.Text.Encoding.UTF8;
binding.UseDefaultWebProxy = false;
binding.Security.Mode = WSDualHttpSecurityMode.None;
StringBuilder sb = new StringBuilder();
sb.Append("http://").Append(GetLocalIp()).Append(":808/WSDualOnXP");
_logger.Debug("Client base address : {1}.", sb.ToString());
binding.ClientBaseAddress = new Uri(sb.ToString());
EndpointAddress endpoint = new EndpointAddress(Settings.Default.ServerAddress);
service = new ProductionServiceClient(instanceContext, binding, endpoint);
//2011-08-25 Test utav clientbase
//service = new ProductionServiceClient(instanceContext, "WsDualTcpEndpoint", Settings.Default.ServerAddress);
_logger.Debug("Server address : {0}.", Settings.Default.ServerAddress);
//ToDo Disabled GeneralDialog.
//2011-05-25 Remove this comment if generaldialog wants to be seen.
//if (scannerNumberList.Count() == 0 || String.IsNullOrEmpty(Settings.Default.ServerAddress))
//{
// GeneralDialog dialog = new GeneralDialog();
// dialog.Show();
// return;
//}
//Subscribe to wcf service.
SubscribeToService(scannerNumberList);
//Keep connection to the service alive.
KeepAlive();
//Start timer for highlight list
GetHighLightListTimer();
//Catch unhandled exceptions
this.DispatcherUnhandledException += new System.Windows.Threading.DispatcherUnhandledExceptionEventHandler(App_DispatcherUnhandledException);
}
private void KeepAlive()
{
_keepAliveTimer.Interval = 31000;
_keepAliveTimer.Elapsed +=
(
(object o, ElapsedEventArgs args) =>
{
try
{
_keepAliveTimer.Stop();
if (service.State != CommunicationState.Opened)
{
if (service != null) { service.Abort(); }
ShowRetryDialog();
RetryToSubscribe();
}
service.KeepConnection();
}
catch (TimeoutException ex)
{
if (service != null) { service.Abort(); }
ShowRetryDialog();
RetryToSubscribe();
}
catch (CommunicationException ex)
{
if (service.State != CommunicationState.Opened)
{
if (service != null) { service.Abort(); }
ShowRetryDialog();
RetryToSubscribe();
}
}
catch
{
if (service != null) { service.Abort(); }
_keepAliveTimer.Stop();
ShowRetryDialog();
RetryToSubscribe();
}
finally
{
_keepAliveTimer.Start();
}
}
);
_keepAliveTimer.Start();
}
还有我的客户回调。
#region ClientCallBacks
//When service callbacks to the client this methods will be triggered.
void clientBack_ClientNotified(object sender, ClientNotifiedEventArgs e)
{
throw new NotImplementedException();
}
void clientBack_RemoveFromDisplayEvent(object sender, RemoveFromDisplayEventArgs e)
{
try
{
_logger.Info("Remove from display.");
userControlChairs.Dispatcher.Invoke((Action)(() =>
{
_queueProductionItems.Remove(e.OrderResponse);
}));
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
void clientBack_AddToDisplayEvent(object sender, AddToDisplayEventArgs e)
{
try
{
_logger.Info("Add to display.");
userControlChairs.Dispatcher.Invoke((Action)(() =>
{
_queueProductionItems.Add(e.OrderResponse);
}));
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
void clientBack_UpdateQueueDisplayEvent(object sender, UpdateQueueDisplayEventArgs e)
{
try
{
_logger.Info("Update queue display.");
userControlQueue.Dispatcher.Invoke((Action)(() =>
{
_queueDisplayItems.Clear();
foreach (OrderDto o in e.UnfinishedOrdersResponse.Orders)
{
_queueDisplayItems.Add(o);
}
}));
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
#endregion
private ObservableOrderResponseQueue _queueProductionItems = new ObservableOrderResponseQueue(); //List of the chairs that will be displayed.
private ObservableCollection<ErrorMessage> _errorMessages = new ObservableCollection<ErrorMessage>(); //List that holds the error message for debug
private ObservableCollection<OrderDto> _queueDisplayItems = new ObservableCollection<OrderDto>();//List of order and quanities left. (DisplayQueue).
private ObservableCollection<DebugInfo> _queueDebugInfo = new ObservableCollection<DebugInfo>(); //
RetryToSubsribe 方法。
public void RetryToSubscribe()
{
try
{
WSDualHttpBinding binding = new WSDualHttpBinding();
binding.Name = "WsDualTcpEndpoint";
binding.CloseTimeout = new TimeSpan(0, 1, 0);
binding.OpenTimeout = new TimeSpan(0, 1, 0);
//binding.ReceiveTimeout = new TimeSpan(0, 0, 30);
binding.SendTimeout = new TimeSpan(0, 1, 0);
binding.BypassProxyOnLocal = false;
binding.TransactionFlow = false;
binding.HostNameComparisonMode = HostNameComparisonMode.StrongWildcard;
binding.MaxBufferPoolSize = 524288;
binding.MaxReceivedMessageSize = 65536;
binding.MessageEncoding = WSMessageEncoding.Text;
binding.TextEncoding = System.Text.Encoding.UTF8;
binding.UseDefaultWebProxy = false;
binding.Security.Mode = WSDualHttpSecurityMode.None;
StringBuilder sb = new StringBuilder();
sb.Append("http://").Append(GetLocalIp()).Append(":808/WSDualOnXP");
_logger.Debug("Client base address : {1}.", sb.ToString());
binding.ClientBaseAddress = new Uri(sb.ToString());
EndpointAddress endpoint = new EndpointAddress(Settings.Default.ServerAddress);
service = new ProductionServiceClient(instanceContext, binding, endpoint);
ClientTokenRequest request = new ClientTokenRequest();
request.RequestId = NewRequestId;
request.StationNumbers = ScannerNumbers;
clientRequest = request;
service.Subscribe(request);
//Close the retry window.
this.Dispatcher.Invoke((Action)(() =>
{
//Set the background to default.
this.MainWindow.SetResourceReference(Window.BackgroundProperty, "MainBackground");
_retryScreen.Hide();
}));
}
catch (Exception ex)
{
_logger.Error(ex.Message);
}
}
【问题讨论】：
-
感谢您的网址。但我的服务没有任何问题。仅在客户端。但是我需要关闭代理吗？如果我关闭它，回调会起作用吗？。
-
据我了解，Duplex 实际上您的客户端也成为了具有自己的通道堆栈的服务。所以如果你关闭从客户端到服务的通道，回调通道应该仍然是打开的。
-
@Tan：没有任何代码，无法分辨。请发布一些服务，更重要的是，客户端代码，以及您的回调设置和回调中的内容。
-
但奇怪的是，这种情况只发生在 Windows XP 中。在 Windows 7 中，内存使用量不会增加。