当试图使用INamedBucketProvider从C#应用程序连接到Couchbase时，出现访问拒绝的错误。

Question

我想使用的界面是 INamedBucketProvider但我得到了 "访问被拒绝 "的错误。IBucketProvider它工作得很完美。

以下是我的代码的一些重要部分。

public interface ICustomerBucketProvider : INamedBucketProvider
{
    // nothing goes in here!
}

public static class IServiceCollectionExtension
{
    public static IServiceCollection AddCouchbaseConnector(this IServiceCollection services)
    {
        services.AddCouchbase(opt => 
        {
            opt.ConnectionString = "couchbase://localhost";
            opt.UserName = "Administrator";
            opt.Password = "asd123";
            opt.Buckets = new[] { "customers" };
        });

        services.AddCouchbaseBucket<ICustomerBucketProvider>("customers");

        return services;
    }
}

public class NativeInjectorBootStrapper
{
    public static void RegisterServices(IServiceCollection services)
    {
        // ...
        // ...
        // ...

        services.AddCouchbaseConnector();
    }
}

这个能用

private readonly IBucketProvider _bucketProvider;

public CustomerEventHandler(IBucketProvider bucketProvider)
{
    _bucketProvider = bucketProvider;
}

private async Task<ICouchbaseCollection> GetCouchbaseCollection()
{
    var bucket = await _bucketProvider.GetBucketAsync("customers");
    var collection = bucket.DefaultCollection();
    return collection;
}

而这个不行

private readonly ICustomerBucketProvider _customerBucketProvider;

public CustomerEventHandler(ICustomerBucketProvider customerBucketProvider)
{
    _customerBucketProvider = customerBucketProvider;
}

private async Task<ICouchbaseCollection> GetCouchbaseCollection()
{
    var bucket = await _customerBucketProvider.GetBucketAsync();
    var collection = bucket.DefaultCollection();
    return collection;
}

我是不是做错了什么？

Answer 1

所以，我决定实现我自己的结构来处理 bucket 和集合。

public interface ICouchbaseBucketBase
{
    public ICouchbaseCollection DefaultCollection { get; }
}

public class CouchbaseBucketBase : ICouchbaseBucketBase
{
    public ICouchbaseCollection DefaultCollection { get; private set; }

    protected readonly IBucket _bucket;

    public CouchbaseBucketBase(IBucketProvider bucketProvider, string bucketName)
    {
        _bucket = bucketProvider.GetBucketAsync(bucketName).GetAwaiter().GetResult();

        DefaultCollection = GetCollection();
    }

    protected ICouchbaseCollection GetCollection(string collectionName = null) =>
        !string.IsNullOrWhiteSpace(collectionName) ?
        _bucket.Collection(collectionName) : _bucket.DefaultCollection();
}

public interface ICustomerBucket : ICouchbaseBucketBase { }

public class CustomerBucket : CouchbaseBucketBase, ICustomerBucket
{
    //public ICouchbaseCollection OtherNonDefaultCollection { get; private set; }

    public CustomerBucket(IBucketProvider bucketProvider) : base(bucketProvider, "customers")
    {
        //OtherNonDefaultCollection = GetCollection("OtherNonDefault");
    }
}

public static class IServiceCollectionExtension
{
    public static IServiceCollection AddCouchbaseConnector(this IServiceCollection services)
    {
        services.AddCouchbase(opt =>
        {
            opt.ConnectionString = "couchbase://localhost";
            opt.UserName = "Administrator";
            opt.Password = "asd123";
            opt.Buckets = new[] { "customers" };
        });

        services.AddTransient<ICustomerBucket, CustomerBucket>();

        return services;
    }
}