We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 401e713 commit b280d89Copy full SHA for b280d89
Go语言微服务(综合大全)/Go-micro/demo/插件使用demo.txt
@@ -0,0 +1,26 @@
1
+import (
2
+ "github.com/micro/go-micro"
3
+ // etcd v3 registry
4
+ "github.com/micro/go-plugins/registry/etcdv3"
5
+ // nats transport
6
+ "github.com/micro/go-plugins/transport/nats"
7
+ // kafka broker
8
+ "github.com/micro/go-plugins/broker/kafka"
9
+)
10
+
11
+func main() {
12
+ registry := etcdv3.NewRegistry()
13
+ broker := kafka.NewBroker()
14
+ transport := nats.NewTransport()
15
16
+ service := micro.NewService(
17
+ micro.Name("greeter"),
18
+ micro.Registry(registry),
19
+ micro.Broker(broker),
20
+ micro.Transport(transport),
21
+ )
22
23
+ service.Init()
24
+ service.Run()
25
+}
26
+Writ
0 commit comments