orleans发送广播消息

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

一个client发送消息给orleans, 就只需要掉用Grain的函数就行了. 但是有时候Grain需要发送消息给client, 在orleans里面, 就只能通过Observer来实现.

public interface IChat : IGrainObserver
{
void ReceiveMessage(string message);
} public class Chat : IChat
{
public void ReceiveMessage(string message)
{
Console.WriteLine(message);
}
} class HelloGrain : Grain, IHello
{
private ObserverSubscriptionManager<IChat> _subsManager;
public override async Task OnActivateAsync()
{
_subsManager = new ObserverSubscriptionManager<IChat>();
await base.OnActivateAsync();
}
public async Task Subscribe(IChat observer)
{
_subsManager.Subscribe(observer);
}
public async Task UnSubscribe(IChat observer)
{
_SubsManager.Unsubscribe(observer);
}
} public Task SendUpdateMessage(string message)
{
_SubsManager.Notify(s => s.ReceiveMessage(message));
return TaskDone.Done;
} //下面就是Grain发送消息给Client的代码
var friend = GrainClient.GrainFactory.GetGrain<IHello>();
Chat c = new Chat(); var obj = await GrainClient.GrainFactory.CreateObjectReference<IChat>(c);
await friend.Subscribe(obj);

有了上面的代码, 我们就可以按照自己的需求造一个广播出来.

发送消息给Client上所有的人
发送消息给Client上某一部分人
发送消息给Client上某一个人

enum DestType
{
DestType_All = ,
DestType_Server = ,
DestType_Player = ,
} //这是我们的观察者
public interface IGatewayObserver : IGrainObserver
{
void SendMessage(int destType, long dest, int msgid, byte[] buffer);
} public interface IAllGatewayGrain : IGrainWithIntegerKey
{
//注册网关
Task RegisterGateway(string key);
Task UnRegisterGateway(string key); //发送消息
Task SendMessage(int destType, long dest, int msgid, byte[] buffer); //注册观察者
Task RegisterObserver(string gateway, IGatewayObserver);
} public interface IGatewayGrain : IGrainWithStringKey
{
Task SendMessage(int destType, long dest, int msgid, byte[] buffer); Task RegisterObserver(string gateway, IGatewayObserver);
}