现已推出与 MongoDB 兼容的 Cloud Firestore 企业版！了解详情。

این صفحه به‌وسیله ‏Cloud Translation API‏ ترجمه شده است.

شمارنده های توزیع شده

بسیاری از برنامه‌های بلادرنگ، اسنادی دارند که به عنوان شمارنده عمل می‌کنند. برای مثال، ممکن است «لایک‌ها»ی یک پست یا «موارد دلخواه» یک آیتم خاص را بشمارید.

در Cloud Firestore ، نمی‌توانید یک سند واحد را با سرعت نامحدود به‌روزرسانی کنید. اگر یک شمارنده بر اساس یک سند واحد داشته باشید و افزایش‌های کافی و مکرر به آن اعمال کنید، در نهایت شاهد اختلاف بر سر به‌روزرسانی‌های سند خواهید بود. به بخش به‌روزرسانی‌های یک سند واحد مراجعه کنید.

راه حل: شمارنده‌های توزیع‌شده

برای پشتیبانی از به‌روزرسانی‌های مکرر شمارنده، یک شمارنده توزیع‌شده ایجاد کنید. هر شمارنده یک سند با زیرمجموعه‌ای از «شاردها» است و مقدار شمارنده مجموع مقدار شاردها است.

توان عملیاتی نوشتن با تعداد شاردها به صورت خطی افزایش می‌یابد، بنابراین یک شمارنده توزیع‌شده با ۱۰ شارد می‌تواند ۱۰ برابر یک شمارنده سنتی، نوشتن انجام دهد.

وب

// counters/${ID}
{
  "num_shards": NUM_SHARDS,
  "shards": [subcollection]
}

// counters/${ID}/shards/${NUM}
{
  "count": 123
}

سویفت

توجه: این محصول در watchOS و App Clip موجود نیست.

// counters/${ID}
struct Counter {
  let numShards: Int

  init(numShards: Int) {
    self.numShards = numShards
  }
}

// counters/${ID}/shards/${NUM}
struct Shard {
  let count: Int

  init(count: Int) {
    self.count = count
  }
}SolutionCountersViewController.swift

هدف-سی

توجه: این محصول در watchOS و App Clip موجود نیست.

// counters/${ID}
@interface FIRCounter : NSObject
@property (nonatomic, readonly) NSInteger shardCount;
@end

@implementation FIRCounter
- (instancetype)initWithShardCount:(NSInteger)shardCount {
  self = [super init];
  if (self != nil) {
    _shardCount = shardCount;
  }
  return self;
}
@end

// counters/${ID}/shards/${NUM}
@interface FIRShard : NSObject
@property (nonatomic, readonly) NSInteger count;
@end

@implementation FIRShard
- (instancetype)initWithCount:(NSInteger)count {
  self = [super init];
  if (self != nil) {
    _count = count;
  }
  return self;
}
@endFIRSolutionCountersViewController.m

Kotlin

// counters/${ID}
data class Counter(var numShards: Int)

// counters/${ID}/shards/${NUM}
data class Shard(var count: Int)SolutionCounters.kt

Java

// counters/${ID}
public class Counter {
    int numShards;

    public Counter(int numShards) {
        this.numShards = numShards;
    }
}

// counters/${ID}/shards/${NUM}
public class Shard {
    int count;

    public Shard(int count) {
        this.count = count;
    }
}SolutionCounters.java

پایتون

import random

from google.cloud import firestore


class Shard:
    """
    A shard is a distributed counter. Each shard can support being incremented
    once per second. Multiple shards are needed within a Counter to allow
    more frequent incrementing.
    """

    def __init__(self):
        self._count = 0

    def to_dict(self):
        return {"count": self._count}


class Counter:
    """
    A counter stores a collection of shards which are
    summed to return a total count. This allows for more
    frequent incrementing than a single document.
    """

    def __init__(self, num_shards):
        self._num_shards = num_shards
distributed_counters.py

Python

import random

from google.cloud import firestore


class Shard:
    """
    A shard is a distributed counter. Each shard can support being incremented
    once per second. Multiple shards are needed within a Counter to allow
    more frequent incrementing.
    """

    def __init__(self):
        self._count = 0

    def to_dict(self):
        return {"count": self._count}


class Counter:
    """
    A counter stores a collection of shards which are
    summed to return a total count. This allows for more
    frequent incrementing than a single document.
    """

    def __init__(self, num_shards):
        self._num_shards = num_shards
distributed_counters.py

نود جی اس

قابل اجرا نیست، به قطعه کد افزایش شمارنده در زیر مراجعه کنید.

برو

import (
	"context"
	"fmt"
	"math/rand"
	"strconv"

	"cloud.google.com/go/firestore"
	"google.golang.org/api/iterator"
)

// Counter is a collection of documents (shards)
// to realize counter with high frequency.
type Counter struct {
	numShards int
}

// Shard is a single counter, which is used in a group
// of other shards within Counter.
type Shard struct {
	Count int
}
solution_counters.go

پی اچ پی

قابل اجرا نیست، به قطعه کد مقداردهی اولیه شمارنده در زیر مراجعه کنید.

سی شارپ

/// <summary>
/// Shard is a document that contains the count.
/// </summary>
[FirestoreData]
public class Shard
{
    [FirestoreProperty(name: "count")]
    public int Count { get; set; }
}Program.cs

کد زیر یک شمارنده توزیع‌شده را مقداردهی اولیه می‌کند:

وب

function createCounter(ref, num_shards) {
    var batch = db.batch();

    // Initialize the counter document
    batch.set(ref, { num_shards: num_shards });

    // Initialize each shard with count=0
    for (let i = 0; i < num_shards; i++) {
        const shardRef = ref.collection('shards').doc(i.toString());
        batch.set(shardRef, { count: 0 });
    }

    // Commit the write batch
    return batch.commit();
}test.solution-counters.js

سویفت

توجه: این محصول در watchOS و App Clip موجود نیست.

func createCounter(ref: DocumentReference, numShards: Int) async {
  do {
    try await ref.setData(["numShards": numShards])
    for i in 0...numShards {
      try await ref.collection("shards").document(String(i)).setData(["count": 0])
    }
  } catch {
    // ...
  }
}SolutionCountersViewController.swift

هدف-سی

}

# # توجه: این محصول در watchOS و App Clip موجود نیست.

- (void)createCounterAtReference:(FIRDocumentReference *)reference shardCount:(NSInteger)shardCount { [reference setData:@{ @"numShards": @(shardCount) } completion:^(NSError * _Nullable error) { for (NSInteger i = 0; i < shardCount; i++) { NSString *shardName = [NSString stringWithFormat:@"%ld", (long)shardCount]; [[[reference collectionWithPath:@"shards"] documentWithPath:shardName] setData:@{ @"count": @(0) }]; } }]; class="devsite-github-link nocode no-select">FIRSolutionCountersViewController.m

Kotlin

fun createCounter(ref: DocumentReference, numShards: Int): Task<Void> { // Initialize the counter document, then initialize each shard. return ref.set(Counter(numShards)) .continueWithTask { task -> if (!task.isSuccessful) { throw task.exception!! } val tasks = arrayListOf<Task<Void>>() // Initialize each shard with count=0 for (i in 0 until numShards) { val makeShard = ref.collection("shards") .document(i.toString()) .set(Shard(0)) tasks.add(makeShard) } Tasks.whenAll(tasks) } class="devsite-github-link nocode no-select">SolutionCounters.kt

شمارنده های توزیع شده با مجموعه‌ها، منظم بمانید ذخیره و طبقه‌بندی محتوا براساس اولویت‌های شما.

راه حل: شمارنده‌های توزیع‌شده

وب

سویفت

هدف-سی

Kotlin

Java

پایتون

Python

نود جی اس

برو

پی اچ پی

سی شارپ

وب

سویفت

هدف-سی

Kotlin

Java

پایتون

Python

نود جی اس

برو

پی اچ پی

سی شارپ

روبی

وب

سویفت

هدف-سی

Kotlin

Java

پایتون

Python

نود جی اس

برو

پی اچ پی

سی شارپ

روبی

وب

سویفت

هدف-سی

Kotlin

Java

پایتون

Python

نود جی اس

برو

پی اچ پی

سی شارپ

روبی

محدودیت‌ها

شمارنده های توزیع شده