使用 Orleans 的相同 Grain 接口的多个实现

Question

我有一个奥尔良应用程序，其结构如下：

public interface IGraintest : Orleans.IGrainWithGuidCompoundKey
{
    Task Init();
}



public abstract class GraintestImpl<T> : Grain, IGraintest, Deserializer<T>
{
    string streamName;
    public Task Init()
    {
        return Task.CompletedTask;
    }


    public override async Task OnActivateAsync()
    {
        var primaryKey = this.GetPrimaryKey(out streamName);
        var streamProvider = GetStreamProvider("SMSProvider");
        var stream = streamProvider.GetStream<String>(primaryKey, streamName);

        // To resume stream in case of stream deactivation
        var subscriptionHandles = await stream.GetAllSubscriptionHandles();

        if (subscriptionHandles.Count > 0)
        {
            foreach (var subscriptionHandle in subscriptionHandles)
            {
                await subscriptionHandle.ResumeAsync(OnNextMessage);
            }
        }

        await stream.SubscribeAsync(OnNextMessage);
    }

    public abstract T Process(string l);

    private Task OnNextMessage(string message, StreamSequenceToken sequenceToken)
    {
        T obj = Process(message);
        //gonna do something with obj here
        return Task.CompletedTask;
    }
}
public class ProcessImplA: GraintestImpl<Car>
{
    public override Car Process(string l)
    {
        return new Car(l);  
    }
}
public class ProcessImplB: GraintestImpl<Boat>
{
    public override Boat Process(string l)
    {
        return new Boat(l);
    }
}

这里我有一个grain，用来从流中读取消息并对它们应用一些操作。由于我想要使用不同的对象类型，因此我创建了一个抽象类来实现该接口。问题就出在这里：

var sourceOne = client.GetGrain<IGraintest>(guid, "Car");
var sourceTwo = client.GetGrain<IGraintest>(guid, "Boat");

当我像这样运行程序时，我收到错误代码：

Exception while trying to run client: Cannot resolve grain interface ID=-<blabla> to a grain class because of multiple implementations of it

所以我的问题是，我可以做一些小的改变来完成这项工作，还是必须为我想要使用的每个 ProcessImpl Grain 创建一个 Grain 接口？

Answer 1

您可以GetGrain使用接受 Grain 类名前缀的重载来消除调用的歧义。

var sourceOne = client.GetGrain<IGraintest>(guid, "Car", grainClassNamePrefix: "MyNamespace.ProcessImplA");
var sourceTwo = client.GetGrain<IGraintest>(guid, "Boat", grainClassNamePrefix: "MyNamespace.ProcessImplB");

否则，如果该接口有两种实现，则运行时不知道如何决定使用哪一种。对于您的情况来说重要的是，有关哪个类实现哪个构造的通用接口的信息对于IGrainFactory，因此它无法选择一个实现。

另一种方法是向您的grain类添加一个标记接口，例如，您可以IGrainTestImplBoat：

public interface IGrainTestImplBoat : Orleans.IGrainWithGuidCompoundKey { }

public class ProcessImplB : GraintestImpl<Boat>, IGrainTestImplBoat { /* ... */ }

var sourceTwo = client.GetGrain<IGrainTestImplBoat>(guid, "Boat");