NATS 文档中文站
首页
概述
NATS 概念
使用 NATS
运行 NATS 服务
参考文档
NGS
NEX
示例
首页
概述
NATS 概念
使用 NATS
运行 NATS 服务
参考文档
NGS
NEX
示例
简体中文

同步订阅

同步订阅要求应用程序等待消息。设置、使用这种类型的订阅都很简单，但如果预期有多个消息，则需要应用程序自己处理循环问题。在只期望单个消息的情况下，同步订阅有时更容易管理，具体取决于所使用的语言。

例如，要订阅 updates 主题并接收一条消息，可以这样做：

{% tabs %} {% tab title="Go" %}

nc, err := nats.Connect("demo.nats.io")
if err != nil {
    log.Fatal(err)
}
defer nc.Close()

// Subscribe
sub, err := nc.SubscribeSync("updates")
if err != nil {
    log.Fatal(err)
}

// Wait for a message
msg, err := sub.NextMsg(10 * time.Second)
if err != nil {
    log.Fatal(err)
}

// Use the response
log.Printf("Reply: %s", msg.Data)

{% endtab %}

{% tab title="Java" %}

Connection nc = Nats.connect("nats://demo.nats.io:4222");

// Subscribe
Subscription sub = nc.subscribe("updates");

// Read a message
Message msg = sub.nextMessage(Duration.ZERO);

String str = new String(msg.getData(), StandardCharsets.UTF_8);
System.out.println(str);

// Close the connection
nc.close();

{% endtab %}

{% tab title="JavaScript" %}

// node-nats subscriptions are always async.

{% endtab %}

{% tab title="Python" %}

# Asyncio NATS client currently does not have a sync subscribe API

{% endtab %}

{% tab title="C#" %}

// NATS .NET subscriptions are always async.

{% endtab %}

{% tab title="Ruby" %}

# The Ruby NATS client subscriptions are all async.

{% endtab %}

{% tab title="C" %}

natsConnection      *conn      = NULL;
natsSubscription    *sub       = NULL;
natsMsg             *msg       = NULL;
natsStatus          s          = NATS_OK;

s = natsConnection_ConnectTo(&conn, NATS_DEFAULT_URL);

// Subscribe
if (s == NATS_OK)
    s = natsConnection_SubscribeSync(&sub, conn, "updates");

// Wait for messages
if (s == NATS_OK)
    s = natsSubscription_NextMsg(&msg, sub, 10000);

if (s == NATS_OK)
{
    printf("Received msg: %s - %.*s\n",
            natsMsg_GetSubject(msg),
            natsMsg_GetDataLength(msg),
            natsMsg_GetData(msg));

    // Destroy message that was received
    natsMsg_Destroy(msg);
}

(...)

// Destroy objects that were created
natsSubscription_Destroy(sub);
natsConnection_Destroy(conn);

{% endtab %} {% endtabs %}