本篇内容主要讲解“Go如何实现共享库”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Go如何实现共享库”吧!
共享库
使用共享库可以协助我们管理代码重用的问题,但是需要考虑共享库依赖和变更控制的问题。
如果有几个服务都使用了一个共享库:
共享库发生变更,每个服务都需要使用新版本共享库。旧版本的共享库如果被弃用就会导致服务不可使用,所以在这种情况下,每次发生变更时就需要重新测试和重新部署服务。
服务发生变更就需要更改共享库,这样共享库就失去通用性的特征。说明共享库包含服务相关的服务的业务逻辑。但这样是错误的,共享库不应该与服务有任何关联的代码块
如果有几个服务都有使用多个共享库:
不同的服务使用不同的库,依赖多个库。共享库越多,依赖就越多,就会导致依赖管理变得困难。
创建库
以Go 操作 RabbitMQ 创建一个共享库为例子,需要初始化 MQ实例,创建连接,重连机制、关闭,消费者通道,创建队列,队列绑定交换机等等功能。
type RabbitMQ struct { connection *amqp.Connection channel *amqp.Channel connURL string errCh <-chan *amqp.Error messageChan <-chan amqp.Delivery retryAttempt int}// 初始化 MQ 实例func NewRabbitMQ(options RabbitMQOptions) (*RabbitMQ, error) { rabbitMQ := &RabbitMQ{ connURL: options.URL, retryAttempt: options.RetryAttempt, } if err := rabbitMQ.connect(); err != nil { return nil, err } return rabbitMQ, nil}func (rmq *RabbitMQ) connect() error {}func (rmq *RabbitMQ) reconnect() {}func (rmq *RabbitMQ) Close() {}func (rmq *RabbitMQ) ConsumeMessageChannel() (jsonBytes []byte, err error) {func (rmq *RabbitMQ) CreateQueue(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args map[string]interface{}) (amqp.Queue, error) }
创建完之后需要再创建一个合适的标签 tag 或版本号来共享该代码。使用过 github 都可以在 release 中看到版本号和 tag 。
使用库
首先,我们需要使用 go get 安装这个共享库。 之后,我们必须在我们的项目中导入我们的库,如下所示。
package mainimport ( "fmt" rabbitmq_sdk "github.com/nanlv/rabbitmq-sdk")func main() { fmt.Println("connect MQ") options := rabbitmq_sdk.RabbitMQOptions{ URL: "amqp://root:root@localhost:5672/", RetryAttempt: 5, } rabbitMQ, err := rabbitmq_sdk.NewRabbitMQ(options) if err != nil { return } queue, err := rabbitMQ.CreateQueue("queue1", true, true, false, false, nil) if err != nil { fmt.Println(err.Error()) return }}
如果你想测试你的库而不发布它,你可以使用 replace 指令。 将依赖库的地址指向本地的文件的地址。
replace github.com/nanlv/rabbitmq-sdk v1.0.0 => 项目在本地的地址
到此,相信大家对“Go如何实现共享库”有了更深的了解,不妨来实际操作一番吧!这里是编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!