预留时间，相约 2024 年 Firebase 演示日了解如何构建和运行用户喜爱的现代化 AI 应用。了解详情。

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

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

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

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

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

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

توان نوشتن با تعداد خرده ها به صورت خطی افزایش می یابد، بنابراین یک شمارنده توزیع شده با 10 قطعه می تواند 10 برابر تعداد نوشته های یک شمارنده سنتی را مدیریت کند.

وب

// 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

هدف-C

توجه: این محصول در اهداف 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+KTX

// 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

Node.js

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

برو

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

PHP

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

سی شارپ

/// <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

هدف-C

}

# # توجه: این محصول در اهداف 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+KTX

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

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

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

وب

سویفت

هدف-C

Kotlin+KTX

Java

پایتون

Python

Node.js

برو

PHP

سی شارپ

وب

سویفت

هدف-C

Kotlin+KTX

Java

پایتون

Python

Node.js

برو

PHP

سی شارپ

روبی

وب

سویفت

هدف-C

Kotlin+KTX

Java

پایتون

Python

Node.js

برو

PHP

سی شارپ

روبی

وب

سویفت

هدف-C

Kotlin+KTX

Java

پایتون

Python

Node.js

برو

PHP

سی شارپ

روبی

محدودیت ها