go-micro examples中broker &event &pubsub 学习（broker发布订阅 & micro api Event + micro 订阅 & ）

examples/broker : micro/go-micro/broker 发布订阅；

examples/event : curl 触发 event + micro api --handler=event + micro service RegisterSubscriber

examples/pubsub : rpc client NewPublisher + micro service micro.RegisterSubscriber

以下是 examples/broker例子

broker 是发布订阅的一个接口

producer/producer.go 代码如下：

package mainimport ("fmt""github.com/go-acme/lego/v3/log""github.com/micro/go-micro/broker""github.com/micro/go-micro/config/cmd""time"//启用 rabbitmq plugin  疑问：从哪里看出 确实使用了rabbitmq？ 没有启动 rabbitmq 服务也可以？_ "github.com/micro/go-plugins/broker/rabbitmq"
)var (topic = "go.micro.topic.foo"
)func pub() {tick := time.NewTicker(time.Second)i := 0for _ = range tick.C {msg := &broker.Message{Header: map[string]string {"id" : fmt.Sprintf("%d", i),},Body : []byte(fmt.Sprintf("%d: %s", i, time.Now().String())),}if err := broker.Publish(topic, msg); err != nil {log.Printf("[pub] failed: %v", err)} else {fmt.Println("[pub] pubbed message:", string(msg.Body))}i++}
}func main() {cmd.Init()if err := broker.Init(); err != nil {log.Fatalf("Broker Init error: %v", err)}if err := broker.Connect(); err != nil {log.Fatalf("Broker Connect error: %v", err)}pub()
}

consumer/consumer.go 代码如下：

package mainimport ("fmt""github.com/go-acme/lego/v3/log""github.com/micro/go-micro/broker""github.com/micro/go-micro/config/cmd"//启用 rabbitmq plugin_ "github.com/micro/go-plugins/broker/rabbitmq"
)var (topic = "go.micro.topic.foo"
)// ???? Example of a shared subscription which receives a subset of messages
func sharedSub() {_, err := broker.Subscribe(topic, func(p broker.Event) error {fmt.Println("[sub] received message:", string(p.Message().Body), "header", p.Message().Header)return nil}, broker.Queue("consumer"))if err != nil {fmt.Println(err)}
}func sub() {_, err := broker.Subscribe(topic, func(p broker.Event) error {fmt.Println("[sub] received message:", string(p.Message().Body), "header", p.Message().Header)return nil})if err != nil {fmt.Println(err)}
}func main() {cmd.Init()if err := broker.Init(); err != nil {log.Fatalf("Broker Init error : %v", err)}if err := broker.Connect(); err != nil {log.Fatalf("Broker Connect error : %v", err)}//sub()sharedSub()select{}
}

broker/main.go 代码如下：

package mainimport ("fmt""github.com/micro/go-micro/broker""github.com/micro/go-micro/config/cmd""log""time"
)var (topic = "go.micro.topic.foo"
)func pub() {tick := time.NewTicker(time.Second)i := 0for _ = range tick.C {msg := &broker.Message{Header: map[string]string{"id": fmt.Sprintf("%d", i),},Body: []byte(fmt.Sprintf("%d: %s", i, time.Now().String())),}if err := broker.Publish(topic, msg); err != nil {log.Printf("[pub] failed: %v", err)} else {fmt.Println("[pub] pubbed message:", string(msg.Body))}i++}
}func sub() {_, err := broker.Subscribe(topic, func(p broker.Event) error {fmt.Println("[sub] received message:", string(p.Message().Body), "header", p.Message().Header)return nil})if err != nil {fmt.Println(err)}
}func main() {cmd.Init()if err := broker.Init(); err != nil {log.Fatal("Broker Init error: %v", err)}if err := broker.Connect(); err != nil {log.Fatal("Broker Connect error: %v", err)}go pub()go sub()//运行 10s 后结束<-time.After(time.Second * 10)
}

go.mod 内容如下：

module brokergo 1.13require (github.com/micro/go-micro v1.18.0 // indirectgithub.com/micro/go-plugins v1.5.1 // indirect
)

运行生产者：

[root@liang broker]# go run producer/producer.go 
[pub] pubbed message: 0: 2020-01-15 14:33:04.480061714 +0800 CST m=+1.004096548
[pub] pubbed message: 1: 2020-01-15 14:33:05.480099439 +0800 CST m=+2.004134292
[pub] pubbed message: 2: 2020-01-15 14:33:06.480700434 +0800 CST m=+3.004735261
[pub] pubbed message: 3: 2020-01-15 14:33:07.481066406 +0800 CST m=+4.005101235

查看微服务 services

[root@liang ~]# micro list services[root@liang ~]#

观察：并没有；

运行消费者：

[root@liang broker]# go run consumer/consumer.go 
[sub] received message: 0: 2020-01-15 14:32:34.721933081 +0800 CST m=+1.004749552 header map[id:0]
[sub] received message: 1: 2020-01-15 14:32:35.72181215 +0800 CST m=+2.004628603 header map[id:1]
[sub] received message: 2: 2020-01-15 14:32:36.722681592 +0800 CST m=+3.005497988 header map[id:2]
[sub] received message: 3: 2020-01-15 14:32:37.722599445 +0800 CST m=+4.005415862 header map[id:3]

再次查看微服务 services

[root@liang ~]# micro list services
go.micro.http.broker

观察：有：“go.micro.http.broker” 如何解释？？？

单独运行 /broker/main.go

root@liang broker]# go run main.go 
[pub] pubbed message: 0: 2020-01-15 14:42:55.741880673 +0800 CST m=+1.011918581
[sub] received message: 0: 2020-01-15 14:42:55.741880673 +0800 CST m=+1.011918581 header map[id:0]
[pub] pubbed message: 1: 2020-01-15 14:42:56.742364591 +0800 CST m=+2.012402518
[sub] received message: 1: 2020-01-15 14:42:56.742364591 +0800 CST m=+2.012402518 header map[id:1]
[pub] pubbed message: 2: 2020-01-15 14:42:57.742303571 +0800 CST m=+3.012341509
[sub] received message: 2: 2020-01-15 14:42:57.742303571 +0800 CST m=+3.012341509 header map[id:2]
[pub] pubbed message: 3: 2020-01-15 14:42:58.742109082 +0800 CST m=+4.012147031
[sub] received message: 3: 2020-01-15 14:42:58.742109082 +0800 CST m=+4.012147031 header map[id:3]
[pub] pubbed message: 4: 2020-01-15 14:42:59.743060533 +0800 CST m=+5.013098463
[sub] received message: 4: 2020-01-15 14:42:59.743060533 +0800 CST m=+5.013098463 header map[id:4]
[pub] pubbed message: 5: 2020-01-15 14:43:00.742296028 +0800 CST m=+6.012333992
[sub] received message: 5: 2020-01-15 14:43:00.742296028 +0800 CST m=+6.012333992 header map[id:5]
[pub] pubbed message: 6: 2020-01-15 14:43:01.743094465 +0800 CST m=+7.013132412
[sub] received message: 6: 2020-01-15 14:43:01.743094465 +0800 CST m=+7.013132412 header map[id:6]
[pub] pubbed message: 7: 2020-01-15 14:43:02.742426186 +0800 CST m=+8.012464104
[sub] received message: 7: 2020-01-15 14:43:02.742426186 +0800 CST m=+8.012464104 header map[id:7]
[pub] pubbed message: 8: 2020-01-15 14:43:03.742289218 +0800 CST m=+9.012327134
[sub] received message: 8: 2020-01-15 14:43:03.742289218 +0800 CST m=+9.012327134 header map[id:8]
[root@liang broker]#

本例子的还有的疑问： broker 插件的使用？如 micro/go-plugins/broker/rabbitmq，kafka 等

---------------------------------------------

以下是 examples/event 对应的例子

这个例子使用 micro api 的事件网关的功能。

一个 http 消息被格式化为一个事件，并把它发布到 go-micro message broker

srv : 一个服务，它订阅了一些事件

srv/proto/pubsub.proto 代码如下：

syntax = "proto3";message Event {//unique idstring id = 1;//unix timestamp;int64 timestamp = 2;//messagestring message = 3;
}

srv/main.go 代码如下

package mainimport ("context""github.com/micro/go-micro"//"log""github.com/micro/go-micro/util/log"//proto "github.com/micro/go-micro/api/proto"proto "event/srv/proto"
)//当 一个消息收到时，Event 的所有方法都会被执行
type Event struct {}func (e *Event) Process(ctx context.Context, event *proto.Event) error {log.Logf("Received event %+v\n", event)//使用 event 做一些事情return nil
}func main()  {service := micro.NewService(micro.Name("user"),)service.Init()//注册 subscribermicro.RegisterSubscriber("go.micro.evt.user", service.Server(), new(Event))if err := service.Run(); err != nil {log.Fatal(err)}
}

go.mod 代码如下：

module eventgo 1.13require github.com/micro/go-micro v1.18.0 // indirect

使用：

带着 event handler 的设置，启动 micro api; 设置时 —namespace 参数指定的值通常被作为topic 名称的一部分。

micro api --handler=event --namespace=go.micro.evt

运行服务：

go run srv/main.go

Event 格式

在接受到消息的最后，这个消息被格式化如下格式：

// A HTTP event as RPC

message Event {

// e.g login

string name = 1;

// uuid

string id = 2;

// unix timestamp of event

int64 timestamp = 3;

// event headers

map<string, Pair> header = 4;

// the event data

string data = 5;

}

发布 Event

使用 POST 请求发送如：

curl -d '{"name": "john"}' http://localhost:8080/user/login

这个请求将被发送到 topic “go.micro.evt.user” event 名是 “login”

接受 Event

subscirber 注册时的时候一定要带着 micro service

subscriber 它接受 proto.Event 类型

收到事件后：事件内容如下：

{

name: "user.login",

id: "go.micro.evt.user-user.login-693116e7-f20c-11e7-96c7-f40f242f6897",

timestamp:1515152077,

header: {...},

data: {"name": "john"}

}

运行 micro api :

[root@liang event]# micro api --handler=event --namespace=go.micro.evt
2020-01-15 15:56:18.597607 I | [api] Registering API Event Handler at /
2020-01-15 15:56:18.601578 I | [api] HTTP API Listening on [::]:8080
2020-01-15 15:56:18.602579 I | [api] Transport [http] Listening on [::]:55779
2020-01-15 15:56:18.602846 I | [api] Broker [http] Connected to [::]:30945
2020-01-15 15:56:18.613099 I | [api] Registry [mdns] Registering node: go.micro.api-6d1890a6-8210-4062-b047-b0022ecad0e9

查看微服务：

[root@liang ~]# micro list services
go.micro.api
go.micro.http.broker
[root@liang ~]#

运行 event service

[root@liang event]# go run srv/main.go
2020-01-15 15:58:32.224459 I | Transport [http] Listening on [::]:60565
2020-01-15 15:58:32.224561 I | Broker [http] Connected to [::]:5481
2020-01-15 15:58:32.232237 I | Registry [mdns] Registering node: user-199d8bd9-6c97-49bc-ae64-80bb81679168
2020-01-15 15:58:32.238025 I | Subscribing user-199d8bd9-6c97-49bc-ae64-80bb81679168 to topic: go.micro.evt.user

再次查看微服务：

[root@liang ~]# micro list services
go.micro.api
go.micro.http.broker
user
[root@liang ~]#

curl 测试：

[root@liang ~]# curl -d '{"name": "john"}' http://localhost:8080/user/login
You have mail in /var/spool/mail/root
[root@liang ~]# curl -d '{"name": "john"}' http://localhost:8080/user/suceessOrder
You have mail in /var/spool/mail/root
[root@liang ~]#

event service 收到消息后的log 如下：

[root@liang event]# go run srv/main.go
2020-01-15 16:14:30.580379 I | Transport [http] Listening on [::]:16217
2020-01-15 16:14:30.580459 I | Broker [http] Connected to [::]:55245
2020-01-15 16:14:30.588822 I | Registry [mdns] Registering node: user-06d7d81f-589c-4b02-87bb-a3ef2e71337f
2020-01-15 16:14:30.594292 I | Subscribing user-06d7d81f-589c-4b02-87bb-a3ef2e71337f to topic: go.micro.evt.user
^[[A2020-01-15 16:15:41.619493 I | Received event id:"suceessOrder" 2:"go.micro.evt.user-suceessOrder-f94ace32-73ba-4135-8f4a-810f62e24b28" 3:1579076141 4:"\n\fContent-Type\x121\n\fContent-Type\x12!application/x-www-form-urlencoded" 4:"\n\nUser-Agent\x12r\n\nUser-Agent\x12dcurl/7.19.7 (x86_64-redhat-linux-gnu) libcurl/7.19.7 NSS/3.27.1 zlib/1.2.3 libidn/1.18 libssh2/1.4.2" 4:"\n\x06Accept\x12\r\n\x06Accept\x12\x03*/*" 4:"\n\x0eContent-Length\x12\x14\n\x0eContent-Length\x12\x0216" 5:"{\"name\": \"john\"}"

event 整理后：
id:"suceessOrder" 
2:"go.micro.evt.user-suceessOrder-f94ace32-73ba-4135-8f4a-810f62e24b28" 
3:1579076141 
4:"\n\fContent-Type\x121\n\fContent-Type\x12!application/x-www-form-urlencoded" 
4:"\n\nUser-Agent\x12r\n\nUser-Agent\x12dcurl/7.19.7 (x86_64-redhat-linux-gnu) libcurl/7.19.7 NSS/3.27.1 zlib/1.2.3 libidn/1.18 libssh2/1.4.2" 4:"\n\x06Accept\x12\r\n\x06Accept\x12\x03*/*" 
4:"\n\x0eContent-Length\x12\x14\n\x0eContent-Length\x12\x0216" 
5:"{\"name\": \"john\"}"

--------------------------------------------------------

以下是 examples/pubsub 例子：

这是一个通过 client/server 接口来实现 pubsub 的例子。

pubsub 在 client/server 层面它很像 RPC 不同的是，它使用异步通信。它使用broker 来发送消息而不是通过使用 transport 接口。

它能够去编码 metadata 到conext, messages 的传输携带 context。

srv/proto/pubsub.proto 代码如下：

syntax = "proto3";// Example message
message Event {// unique idstring id = 1;// unix timestampint64 timestamp = 2;// messagestring message = 3;
}

srv/main.go 代码如下：

package mainimport ("context""github.com/micro/go-micro/metadata""github.com/micro/go-micro/server""github.com/micro/go-micro/util/log""github.com/micro/go-micro"proto "pubsub/srv/proto"
)type Sub struct {}func (s *Sub) Process(ctx context.Context, event *proto.Event) error {md, _ := metadata.FromContext(ctx)log.Logf("[pubsub.1] Received event %+v with metadata %+v\n", event, md)//使用 event 做一些事情return nil
}//替代地，也可以使用func
func subEv (ctx context.Context, event *proto.Event) error {md, _ := metadata.FromContext(ctx)log.Logf("[pubsub.2] Received event %+v with metadata %+v\n", event, md)//使用event 做一些事情return nil
}func main() {service := micro.NewService(micro.Name("go.micro.srv.pubsub"),)//解析命令行service.Init()//注册 subscribermicro.RegisterSubscriber("example.topic.pubsub.1", service.Server(), new(Sub))//使用上 queue 的 subscriber 的注册。micro.RegisterSubscriber("example.topic.pubsub.2", service.Server(),subEv, server.SubscriberQueue("queue.pubsub"))if err := service.Run(); err != nil {log.Fatal(err)}}

cli/main.go 代码如下：

package mainimport ("context""fmt""github.com/go-log/log""github.com/pborman/uuid""github.com/micro/go-micro""time"proto "pubsub/srv/proto"
)//使用 publisher 发送 events
func sendEv(topic string, p micro.Publisher) {t := time.NewTicker(time.Second)for _ = range t.C {ev := &proto.Event{Id : uuid.NewUUID().String(),Timestamp: time.Now().Unix(),Message: fmt.Sprintf("Message you all day on %s", topic),}log.Logf("publishing %v", ev)//发布 一个 eventif err := p.Publish(context.Background(), ev); err != nil {log.Logf("error publishing: %v", err)}}
}func main() {//创建服务service := micro.NewService(micro.Name("go.micro.cli.pubsub"),)//解析 命令行service.Init()//创建 发布器pub1 := micro.NewPublisher("example.topic.pubsub.1", service.Client())pub2 := micro.NewPublisher("example.topic.pubsub.2", service.Client())//发布到 topic 1go sendEv("example.topic.pubsub.1", pub1)//发布到 topic 2go sendEv("example.topic.pubsub.2", pub2)//阻塞select{}}

go.mod 内容如下：

module pubsubgo 1.13require (github.com/micro/go-micro v1.18.0 // indirectgithub.com/pborman/uuid v1.2.0 // indirect
)

运行： srv/main.go

[root@liang pubsub]# go run srv/main.go 
2020-01-15 17:42:51.544857 I | Transport [http] Listening on [::]:22856
2020-01-15 17:42:51.544991 I | Broker [http] Connected to [::]:51092
2020-01-15 17:42:51.545707 I | Registry [mdns] Registering node: go.micro.srv.pubsub-6e4cb817-9431-4dd1-b2b3-acf0f56fd14a
2020-01-15 17:42:51.555496 I | Subscribing go.micro.srv.pubsub-6e4cb817-9431-4dd1-b2b3-acf0f56fd14a to topic: example.topic.pubsub.1
2020-01-15 17:42:51.557270 I | Subscribing go.micro.srv.pubsub-6e4cb817-9431-4dd1-b2b3-acf0f56fd14a to topic: example.topic.pubsub.2

查看微服务

[root@liang ~]# micro list services
go.micro.http.broker
go.micro.srv.pubsub
[root@liang ~]#

运行 client

[root@liang pubsub]# go run cli/main.go

再次查看服务：

[root@liang ~]# micro list services
go.micro.http.broker
go.micro.srv.pubsub
[root@liang ~]#

服务端的log:

[root@liang pubsub]# go run srv/main.go 
2020-01-15 17:41:21.616840 I | Transport [http] Listening on [::]:65423
2020-01-15 17:41:21.616918 I | Broker [http] Connected to [::]:31354
2020-01-15 17:41:21.625304 I | Registry [mdns] Registering node: go.micro.srv.pubsub-09737d5a-9a08-4c6a-b880-53ea2a49def8
2020-01-15 17:41:21.642703 I | Subscribing go.micro.srv.pubsub-09737d5a-9a08-4c6a-b880-53ea2a49def8 to topic: example.topic.pubsub.1
2020-01-15 17:41:21.644025 I | Subscribing go.micro.srv.pubsub-09737d5a-9a08-4c6a-b880-53ea2a49def8 to topic: example.topic.pubsub.2
2020-01-15 17:41:52.142755 I | [pubsub.1] Received event id:"42429a90-377b-11ea-b33c-000c297458cb" timestamp:1579081312 message:"Message you all day on example.topic.pubsub.1"  with metadata map[Content-Type:application/protobuf Micro-From-Service:go.micro.cli.pubsub Micro-Id:cd98f557-7d3e-43a8-b18b-71f538c6bb14 Micro-Topic:example.topic.pubsub.1]
2020-01-15 17:41:52.143912 I | [pubsub.2] Received event id:"4242a28b-377b-11ea-b33c-000c297458cb" timestamp:1579081312 message:"Message you all day on example.topic.pubsub.2"  with metadata map[Content-Type:application/protobuf Micro-From-Service:go.micro.cli.pubsub Micro-Id:1bf7d975-f483-46dc-9c2e-e4ce0fcff76b Micro-Topic:example.topic.pubsub.2]
2020-01-15 17:41:53.039169 I | [pubsub.1] Received event id:"42db227c-377b-11ea-b33c-000c297458cb" timestamp:1579081313 message:"Message you all day on example.topic.pubsub.1"  with metadata map[Content-Type:application/protobuf Micro-From-Service:go.micro.cli.pubsub Micro-Id:60d343dc-3826-4a59-9c96-fa27a8cd3118 Micro-Topic:example.topic.pubsub.1]

查看全文
如若内容造成侵权/违法违规/事实不符，请联系编程学习网邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！

POJ 1015
题目来源：http://poj.org/problem?id=1015较难的一道动态规划，具体见代码。dp[i][j]能够转移到dp[i+1][j+x]n个人中存在一个x=p[?]-d[?]成立且dp[i][j]+p[?]+d[?]要比dp[i+1][j+x]大#include<iostream> #include<cstdio> #include<cstring> #include&…...
2024/3/29 12:41:13
JVM 调优实战--垃圾收集器（串行、ParNew并行、ParallelNew并行、CMS、G1）
目录串行垃圾收集器编写测试代码设置垃圾回收器为串行垃圾回收器并行垃圾收集器ParNew垃圾收集器idea设置为ParNewParallelGC垃圾收集器idea中设置为ParallelGC CMS垃圾收集器idea设置为CMS垃圾回收器G1垃圾收集器原理Young GCRememberedSet已记忆集合Mixed GC全局并发标记拷贝…...
2024/3/29 12:41:11
FSGAN: Subject Agnostic Face Swapping and Reenactment（ICCV19）
3. Face swapping GAN 定义source face image为IsI_sIs，target face image为ItI_tIt FSGAN包含3个部分...
2024/4/21 0:45:34
The given artifact contains a string literal with a package reference 'android.support.v4.content' t
运行项目出现如下问题The given artifact contains a string literal with a package reference android.support.v4.content that cannot be safely rewritten. Libraries using reflection such as annotation processors need to be updated manually to add support for an…...
2024/3/29 12:41:09
Andorid apk反编译
1、使用APKtool在cmd命令窗口，中输出： apktool d 您拿到这个文件夹下的需要反编译的apk文件名.apk，就会生成appDebug文件夹，里面会可以看到res资源文件和AndroidManifest.xml文件，如下图：2、使用 dex2jar生成classes-dex2jar文件把.apk文件改成.zip文件，解压：得到cla…...
2024/4/22 2:21:52
replaceAll("[\\pP‘’“”]", ",").split(",");
所有特殊符号改为 , 逗号replaceAll("[\\pP‘’“”]", ",").split(",");...
2024/3/29 12:41:07
golang刷题之和为S的连续正数序列
题目：小明很喜欢数学,有一天他在做数学作业时,要求计算出9~16的和,他马上就写出了正确答案是100。但是他并不满足于此,他在想究竟有多少种连续的正数序列的和为100(至少包括两个数)。没多久,他就得到另一组连续正数和为100的序列:18,19,20,21,22。现在把问题交给你,你能不能也…...
2024/4/1 23:15:48
一、Django 简介
Django 是一个由 Python 写成的开放源代码的 Web 应用框架。它最初是被开发来用于管理劳伦斯出版集团旗下的一些以新闻内容为主的网站的，即是 CMS（内容管理系统）软件。并于2005年7月在 BSD 许可证下发布。这套框架是以比利时的吉普赛爵士吉他手 Django Reinhardt 来命名的。…...
2024/3/29 7:43:04
Spark大数据-TMDB电影数据分析（spark-scala版）
TMDB电影数据分析（spark-scala版，pyspark版本）基于kaggle的TMDB电影数据集的数据分析，该数据集包含大约 5000 部电影的相关数据，TMDB数据下载。分析电影关键词的分布、电影投入以及收益评价等之间的关系，并使用Python web进行可视化。一.环境要求（仅供参考） centos7、…...
2024/3/29 7:43:03
【MySQL】 mysql日期相加减
MySQL的日期相加减，懂一个方法，即可会所有的日期相加减。语法：DATE_ADD(date,INTERVAL expr type) 如日期加一个月：select date_add(NOW(), interval 1 MONTH); 其中： date_add() 增加 date_sub()减少或者数字正负也代表加减。 type可选值为：毫秒: MICROSECOND 秒：…...
2024/5/4 2:37:54
Power Integrations推出的高可靠性SCALE-iDriver门极驱动器已通过AEC-Q100汽车级认证
紧凑、高效的SID1181KQ门极驱动器可确保系统安全美国加利福尼亚州圣何塞--(美国商业资讯)--深耕于中高压逆变器应用门极驱动器技术领域的知名公司Power Integrations（纳斯达克股票代号：POWI）今日推出适合额定电压750V IGBT的汽车级SID1181KQ SCALE-iDriver™门极驱动器。继推…...
2024/3/29 7:42:59
干掉服务状态！从 Session 到 Token，复杂度降低100倍
转载：https://mp.weixin.qq.com/s/UzO9Jp79RqGSSMP5GzbVxw作者：会点代码的大叔在讲Token之前，先简单说说什么是 Session 和 Cookie。首先要知道 HTTP 请求是无状态的；无状态的意思就是：每一次请求都是独立的；每一次请求不会受到前面请求的影响，也不会影响后面的请求；比…...
2024/5/6 8:24:18
three.js中的事件
以上一篇入门篇为例来简单的设置下3d模型当中的交互事件，上一篇我们已经完成了在3d页面中添加了一个红色球，下面我们给这个球一个点击事件让它Y轴位置上升，再设置一个鼠标移入到球上时让其变色。 1.其实three.js当中没有事件可以直接选中物体的，我们需要监听window对象来完…...
2024/4/9 22:08:09
Qtum量子链2020技术路线图详解，布局三大板块全面提升性能
正文共：2,201 字预计阅读时间：6 分钟概述 Qtum 刚刚发布了最新的 2020 年技术路线图，包含离线 Staking，Qtum Phantom 隐私解决方案和 Qtum Neutron 虚拟机架构三大更新。路线图中罗列了众多技术目标，但对于大部分用户来说，这些概念太过于抽象。本文将对技术路线图进行进…...
2024/4/27 1:04:37
TiDB基本简介
由于目前的项目把mysql换成了TiDb，所以特意来了解下tidb。其实也不能说换，由于tidb和mysql几乎完全兼容，所以我们的程序没有任何改动就完成了数据库从mysql到TiDb的转换，TiDB 是一个分布式 NewSQL (SQL 、 NoSQL 和 NewSQL 的优缺点比较 )数据库。它支持水平弹性扩展、ACID…...
2024/4/10 1:18:04
NAT：网络地址转换
NAT：网络地址转换 1.工作原理在一台路由器上对进或出的流量进行ip地址的修改，常用规则为从内部去往外部时修改源ip地址；从外部进入内部时修改目标ip地址；NAT技术最大的优点是：节省了大量的IP资源 2.IPV4地址存在私有和公有的区别：私有地址：本地唯一性，不能在互联网中通…...
2024/4/1 11:50:34
趣谈编程史第2期-这个世界缺少对C语言的敬畏,你不了解的C语言科普
这是我制作的编程语言科普系列视频的第二期,博客根据视频文案整理而成,提供给有需要的朋友阅读或使用.视频地址:https://www.bilibili.com/video/av83627932/ 如果感兴趣观看视频,感谢博友.在华夏文明的历史长卷中,曾经有一段狼烟四起,群雄逐鹿的特殊历史时期史称春秋战国这段…...
2024/3/29 12:41:04
“微软超级漏洞”？关于CVE-2020-0601的官方回复
随着微软发布漏洞补丁，多家媒体先后报道，但对漏洞描述与官方公开文档有一定出入。微软内部人员称：部分媒体存在选择性说明事实、夸大事实、恶意揣测和发布不负责任的虚假内容的情况。基于此，笔者想和大家客观地梳理一下此次所谓的“微软超级漏洞”。在微软例行公布的1月补丁…...
2024/3/29 12:41:03
微服务，为什么从前后端分离开始？
既要低头赶路，又要抬头望天，科技是为人服务的，任何技术背后都有更深层次的考量，在本系列的第一篇文章中我们聊了微服务的本质，它是一种可以加速分工、促进合作的新协作机制。知其然，知其所以然，在第二篇文章中我们剖析了微服务为什么可以加速分工、促进合作，今天我们再…...
2024/3/29 12:41:02
sqlserver on linux always on 安装配置
以下步骤仅为个人安装测试记录，未在生产环境实际用过，谨慎用于生产环境。一、不支持的功能和服务类型不支持的功能或服务备注数据库引擎事务复制所有数据更改都会以事务为单位，按照其在发布服务器上发生的顺序，同步到订阅服务器上，2019起支持合并复制允许用户同时修改订阅…...
2024/4/24 14:24:29

go-micro examples中broker &event &pubsub 学习（broker发布订阅 & micro api Event + micro 订阅 & ）

相关文章

最新文章