Nats 消息队列
August 21, 2024About 1 min
What is NATS?
Official Documentation
NATS is an open-source, distributed messaging system based on the publish-subscribe mechanism. Its main features include:
- High Performance: NATS is known for its low latency and high throughput, making it suitable for scenarios requiring fast message delivery.
- Simplicity: NATS provides a simple API and supports multiple programming languages, making it easy for developers to integrate.
- Flexible Messaging Patterns: NATS supports various messaging patterns, including publish-subscribe, request-response, and queue groups.
- Persistence Options: While core NATS does not support message persistence, NATS JetStream offers persistent message queue functionality.
Adding NATS Configuration
etc
NatsConf:
Hosts:
- "nats://localhost:4222"
ReconnectWait: 10
MaxReconnect: 10
Supported Configurations
Name | Default Value | Description |
---|---|---|
Hosts | None | Server addresses, in list form |
ReconnectWait | 5 (seconds) | Retry wait time |
MaxReconnect | 5 (times) | Maximum retry attempts |
UserCred | None | Path to authorization cred file |
NkeyFile | None | Path to N Key file |
TlsClientCert | None | Path to TLS client certificate |
TlsClientKey | None | Path to TLS client key |
TlsCACert | None | Path to TLS CA certificate |
UserJwt | None | User JWT token |
Adding Configuration to config
package config
import (
"github.com/suyuan32/simple-admin-common/plugins/casbin"
"github.com/suyuan32/simple-admin-common/plugins/mq/asynq"
"github.com/suyuan32/simple-admin-common/plugins/mq/nats"
"github.com/zeromicro/go-zero/core/stores/redis"
"github.com/zeromicro/go-zero/zrpc"
"github.com/suyuan32/simple-admin-common/config"
)
type Config struct {
zrpc.RpcServerConf
DatabaseConf config.DatabaseConf
CasbinConf casbin.CasbinConf
RedisConf redis.RedisConf
AsynqConf asynq.AsynqConf
NatsConf nats.Conf
}
Add init codes to service_context
package svc
import (
"github.com/hibiken/asynq"
"github.com/suyuan32/simple-admin-core/rpc/ent"
"github.com/suyuan32/simple-admin-core/rpc/internal/config"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/stores/redis"
)
type ServiceContext struct {
Config config.Config
DB *ent.Client
Redis *redis.Redis
MQProducer *asynq.Client
Nats jetstream.JetStream
}
func NewServiceContext(c config.Config) *ServiceContext {
db := ent.NewClient(
ent.Log(logx.Info), // logger
ent.Driver(c.DatabaseConf.NewNoCacheDriver()),
ent.Debug(), // debug mode
)
nats, err := c.NatsConf.NewJetStream()
logx.Must(err)
return &ServiceContext{
Config: c,
DB: db,
Redis: redis.MustNewRedis(c.RedisConf),
MQProducer: asynq.NewClient(c.AsynqConf.WithRedisConf(c.RedisConf).NewRedisOpt()),
Nats: nats,
}
}
Info
Use c.NatsConf.NewConnection()
initialize nats connection or use c.NatsConf.NewJetStream()
to initialize jetstream connection