Есть проблема
пишу расперделённое приложение, проблема заключется в следущем, при вызове делегатов удалённого объекта не у всех клиентов срабатывают обработчики. Почти всегда клиент потом просто висит(если это виндовозовская форма), если простое консольное приложение, то в случае 2 клиентов работает всё почти нормально, а вот когда больше клиентов начинаюся неприятности
вот код, он практически идентичен, написанному в известной книге
сервер:
| Код |
using System;
using System.Collections.Generic;
using System.Text;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Channels.Tcp;
using System.Collections.Specialized;
namespace Server
{
class Program
{
static void Main(string[] args)
{
ListDictionary channelProperties = new ListDictionary();
channelProperties.Add("port", 4000);
BinaryServerFormatterSinkProvider serverSinkProvider = new BinaryServerFormatterSinkProvider();
serverSinkProvider.TypeFilterLevel = System.Runtime.Serialization.Formatters.TypeFilterLevel.Full;
TcpChannel channel = new TcpChannel(channelProperties, null, serverSinkProvider);
ChannelServices.RegisterChannel(channel);
RemotingConfiguration.RegisterWellKnownServiceType(typeof(Messager), "Messager",
WellKnownObjectMode.Singleton);
Messager msg = new Messager();
ObjRef obj = RemotingServices.Marshal(msg, "TcpService");
Console.WriteLine("Input Enter to exit..");
Console.ReadLine();
}
}
}
|
удалённый объект:
| Код |
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Runtime.Remoting;
using System.Windows.Forms;
public delegate void MsgEventHandler(string msg);
public interface IServer
{
event MsgEventHandler MsgEvent;
void Notify(string msg);
}
public class Messager : MarshalByRefObject, IServer
{
public event MsgEventHandler MsgEvent;
public override object InitializeLifetimeService()
{
return null;
}
public void Notify(string msg)
{
System.Delegate[] invkList = MsgEvent.GetInvocationList();
IEnumerator ie = invkList.GetEnumerator();
while (ie.MoveNext())
{
MsgEventHandler handler = (MsgEventHandler)ie.Current;
try
{
handler.Invoke(msg);
//может стоит использовать BeginInvoke, только не знаю какие параметры:(
}
catch (Exception e)
{
MsgEvent -= handler;
}
}
}
}
public class MessagerRepeater : MarshalByRefObject
{
public event MsgEventHandler MsgEvent;
public void Handler(string msg)
{
if (MsgEvent != null)
{
MsgEvent(msg);
}
}
public override object InitializeLifetimeService()
{
return null;
}
}
|
и сам клиент:
| Код |
using System.Runtime.Remoting;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Channels.Tcp;
using System;
using System.Collections;
namespace Client
{
class Program
{
public static void MessageReceived(string msg)
{
Console.WriteLine("Принято: "+msg);
}
static void Main(string[] args)
{
Hashtable props = new Hashtable();
props.Add("port", 0);
BinaryServerFormatterSinkProvider serverSinkProvider = new BinaryServerFormatterSinkProvider();
serverSinkProvider.TypeFilterLevel = System.Runtime.Serialization.Formatters.TypeFilterLevel.Full;
TcpChannel channel = new TcpChannel(props, null, serverSinkProvider);
channel.StartListening(0);
ChannelServices.RegisterChannel(channel);
RemotingConfiguration.RegisterWellKnownClientType(typeof(Messager), "tcp://localhost:4000/Messager");
IServer m_msg = (IServer)new Messager();
MessagerRepeater m_rep = new MessagerRepeater();
m_msg.MsgEvent+=new MsgEventHandler(m_rep.Handler);
m_rep.MsgEvent += new MsgEventHandler(MessageReceived);
Console.WriteLine("Вдави exit для выхода");
string msg;
do
{
msg = Console.ReadLine();
m_msg.Notify(msg);
}
while (msg != "exit");
Console.ReadLine();
}
}
}
|
в чём дело не пойму, вроде всё должно работать, а почему то сообщения до некоторых клиентов не доходят, а с формами вообще страшное дело клиент-инициатор приказывает долго жить, а другие клиенты перехватывают сообщения в 50%hmmm инструмент-студия 8
ЗЫ не хочу создавать новую тему, поэтому ещё один вопрос, где можно достать информацию по сокетам и как с ними работать в С#, желательно на русском языке 
что я не так сделал? |
, хотя в удалённом объекте она должна гарантировать "бескнечную жизнь" удалённого объекта
