云 Pub/Sub 订阅者在超过 600 毫秒的时间内重复接收消息。

在使用云 Pub/Sub 订阅者时，可以使用一个定时器来检测超过 600 毫秒时间内是否重复接收消息。以下是一个使用 Python 和 Google Cloud Pub/Sub 客户端库的示例代码：

import time
from google.cloud import pubsub_v1

subscriber = pubsub_v1.SubscriberClient()
subscription_path = "projects/{project_id}/subscriptions/{subscription_id}"

def callback(message):
    print("Received message:", message.data)
    message.ack()

def receive_messages():
    streaming_pull_future = subscriber.subscribe(subscription_path, callback=callback)
    print("Listening for messages...")
    
    timer_start = time.time()
    while True:
        if time.time() - timer_start > 0.6:
            streaming_pull_future.cancel()
            print("Stopped receiving messages due to timeout.")
            break

        try:
            streaming_pull_future.result(timeout=0.1)
        except Exception as e:
            print("Error:", e)

receive_messages()

在上面的示例中，我们创建了一个名为 receive_messages 的函数，它使用 subscriber.subscribe 方法来订阅指定的主题和回调函数 callback。我们还定义了一个定时器，如果超过 600 毫秒，就会取消订阅并停止接收消息。

在 callback 函数中，我们可以处理接收到的消息，例如打印消息内容并调用 message.ack() 以确认消息已被处理。

请注意，上述代码只是一个示例，实际应用中可能需要根据具体的需求进行适当的修改。