金慶的專欄
C++博客
::
首頁
::
新隨筆
::
聯(lián)系
::
聚合
::
管理
::
423 隨筆 :: 0 文章 :: 454 評論 :: 0 Trackbacks
公告
我的隨筆
我的評論
我參與的隨筆
留言簿
(12)
給我留言
查看公開留言
查看私人留言
隨筆分類
(502)
1. C/C++(166)
(rss)
2. 網(wǎng)游開發(fā)(108)
(rss)
3. Golang(20)
(rss)
4. Linux/Unix(30)
(rss)
5. 軟工與管理(44)
(rss)
6. Python(23)
(rss)
7. Erlang(18)
(rss)
8. Rust(16)
(rss)
9. 其它(77)
(rss)
隨筆檔案
(423)
2023年1月 (1)
2022年11月 (1)
2022年10月 (2)
2022年9月 (1)
2022年4月 (6)
2022年1月 (2)
2021年12月 (4)
2021年11月 (6)
2021年10月 (2)
2021年9月 (2)
2021年8月 (7)
2021年7月 (2)
2021年5月 (2)
2021年3月 (1)
2021年2月 (2)
2021年1月 (1)
2020年12月 (1)
2020年10月 (1)
2020年9月 (5)
2020年8月 (1)
2020年7月 (1)
2020年6月 (1)
2020年4月 (2)
2020年3月 (3)
2020年2月 (3)
2020年1月 (1)
2019年12月 (1)
2019年9月 (2)
2019年4月 (2)
2019年1月 (1)
2018年12月 (1)
2018年11月 (3)
2018年10月 (1)
2018年9月 (3)
2018年8月 (3)
2018年7月 (2)
2018年6月 (4)
2018年5月 (4)
2018年4月 (4)
2018年3月 (1)
2018年1月 (2)
2017年12月 (2)
2017年11月 (3)
2017年10月 (3)
2017年8月 (7)
2017年7月 (1)
2017年6月 (1)
2017年5月 (3)
2017年4月 (3)
2017年3月 (3)
2017年2月 (2)
2017年1月 (2)
2016年12月 (5)
2016年11月 (2)
2016年10月 (2)
2016年9月 (1)
2016年8月 (6)
2016年7月 (3)
2016年6月 (2)
2016年5月 (4)
2016年4月 (2)
2016年3月 (2)
2016年1月 (3)
2015年12月 (2)
2015年11月 (2)
2015年10月 (1)
2015年8月 (2)
2015年7月 (1)
2015年6月 (1)
2015年5月 (4)
2015年4月 (3)
2015年3月 (4)
2015年2月 (5)
2015年1月 (4)
2014年12月 (3)
2014年11月 (3)
2014年10月 (2)
2014年9月 (3)
2014年8月 (1)
2014年4月 (4)
2014年3月 (1)
2014年2月 (4)
2014年1月 (5)
2013年12月 (5)
2013年11月 (5)
2013年9月 (2)
2013年8月 (2)
2013年7月 (2)
2013年6月 (2)
2013年5月 (1)
2013年1月 (2)
2012年12月 (1)
2012年11月 (1)
2012年9月 (1)
2012年8月 (3)
2012年7月 (2)
2012年6月 (1)
2012年4月 (3)
2012年3月 (2)
2012年2月 (3)
2012年1月 (2)
2011年11月 (2)
2011年10月 (3)
2011年9月 (2)
2011年8月 (2)
2011年7月 (3)
2011年6月 (2)
2011年5月 (3)
2011年1月 (2)
2010年12月 (1)
2010年11月 (2)
2010年10月 (2)
2010年9月 (3)
2010年8月 (2)
2010年7月 (3)
2010年6月 (1)
2010年5月 (3)
2010年4月 (3)
2010年3月 (5)
2010年2月 (4)
2010年1月 (4)
2009年12月 (2)
2009年11月 (3)
2009年10月 (4)
2009年9月 (3)
2009年8月 (2)
2009年7月 (4)
2009年6月 (1)
2009年5月 (3)
2009年4月 (4)
2009年3月 (2)
2009年2月 (5)
2009年1月 (1)
2008年12月 (7)
2008年11月 (4)
2008年10月 (1)
2008年9月 (3)
2008年8月 (4)
2008年7月 (3)
2008年6月 (4)
2008年5月 (6)
2008年4月 (7)
2008年3月 (6)
2008年1月 (5)
2007年12月 (7)
2007年11月 (4)
2007年10月 (5)
2007年9月 (6)
2007年8月 (8)
2007年7月 (5)
相冊
公告照片
搜索
積分與排名
積分 - 656636
排名 - 25
最新評論
1.?re: boost::asio::spawn 將一統(tǒng)C++網(wǎng)絡庫
asio 成為C++首選網(wǎng)絡庫
--linda
2.?re: log4cxx中文輸出錯誤補丁
評論內(nèi)容較長,點擊標題查看
--金慶
3.?re: mingw編譯OrzNet
能發(fā)送一個mingw編譯好的OrzNet庫給我嗎? liuweiqcxy@163.com
謝謝!
--劉威
4.?re: log4cxx中文輸出錯誤補丁
評論內(nèi)容較長,點擊標題查看
--bigbad
5.?re: log4cxx中文輸出錯誤補丁
評論內(nèi)容較長,點擊標題查看
--bigbad
閱讀排行榜
1.?"multiple definition of" 錯誤(11032)
2.?SVN中邪惡的replace(10955)
3.?VS2005編譯libevent(10413)
4.?混音算法的學習與研究(10203)
5.?C調(diào)用lua腳本的效率測試(9007)
評論排行榜
1.?VC6正在被拋棄(35)
2.?VS2005編譯libevent(21)
3.?"multiple definition of" 錯誤(18)
4.?C++引用優(yōu)于指針(17)
5.?ACE與ASIO之間關于Socket編程的比較(16)
gRPC-go 連接管理
gRPC-go 連接管理
(金慶的專欄 2017.12)
把 example greeter 改一下,處理 SayHello() 請求時,不僅僅返回本次請求者的名字,
還返回上次請求的名字,如:
```
λ go run greeter_client/main.go
2017/12/25 17:59:13 Greeting: Hello 'world' (prev '')
2017/12/25 17:59:15 Greeting: Hello 'world2' (prev 'world')
```
先將客戶端單次請求改為多次請求:
```go
r, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: name})
log.Printf("Greeting: %s", r.Message)
time.Sleep(2 * time.Second)
r, err = c.SayHello(context.Background(), &pb.HelloRequest{Name: name + "2"})
log.Printf("Greeting: %s", r.Message)
...
```
服務器需要為每個連接保存各自的數(shù)據(jù)。連接創(chuàng)建時初始化數(shù)據(jù),連接斷開時清理數(shù)據(jù)。
這里利用了連接統(tǒng)計的接口,不知道是否是最適當?shù)膶崿F(xiàn)方式?
服務器創(chuàng)建時添加 StatsHandler 選項,輸入一個 stats.Handler 的實現(xiàn)。
```
- s := grpc.NewServer()
+ s := grpc.NewServer(grpc.StatsHandler(&statshandler{}))
```
statshandler 需實現(xiàn)4個方法,只用到2個連接相關的方法,TagConn() 和 HandleConn(),
另外2個 TagRPC() 和 HandleRPC() 用于RPC統(tǒng)計, 實現(xiàn)為空。
```go
type statshandler struct{}
// TagConn 用來給連接打個標簽,以此來標識連接(實在是找不出還有什么辦法來標識連接).
// 這個標簽是個指針,可保證每個連接唯一。
// 將該指針添加到上下文中去,鍵為 connCtxKey{}.
func (h *statshandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context {
return context.WithValue(ctx, connCtxKey{}, info)
}
// TagRPC 為空.
func (h *statshandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context {
return ctx
}
// HandleConn 會在連接開始和結束時被調(diào)用,分別會輸入不同的狀態(tài).
func (h *statshandler) HandleConn(ctx context.Context, s stats.ConnStats) {
tag, ok := getConnTagFromContext(ctx)
if !ok {
log.Fatal("can not get conn tag")
}
connsMutex.Lock()
defer connsMutex.Unlock()
switch s.(type) {
case *stats.ConnBegin:
conns[tag] = ""
log.Printf("begin conn, tag = (%p)%#v, now connections = %d\n", tag, tag, len(conns))
case *stats.ConnEnd:
delete(conns, tag)
log.Printf("end conn, tag = (%p)%#v, now connections = %d\n", tag, tag, len(conns))
default:
log.Printf("illegal ConnStats type\n")
}
}
// HandleRPC 為空.
func (h *statshandler) HandleRPC(ctx context.Context, s stats.RPCStats) {
}
```
用一個map來管理所有連接,以連接的標簽(是個指針)為鍵,值為上次請求者的名字。
因為有多線程訪問,所有加個 Mutex 來保護。
連接結束時,將從 conns 中刪除連接相關的數(shù)據(jù)。
```go
var connsMutex sync.Mutex
var conns map[*stats.ConnTagInfo]string = make(map[*stats.ConnTagInfo]string)
```
getConnTagFromContext() 從上下文中取連接標簽:
```go
type connCtxKey struct{}
func getConnTagFromContext(ctx context.Context) (*stats.ConnTagInfo, bool) {
tag, ok := ctx.Value(connCtxKey{}).(*stats.ConnTagInfo)
return tag, ok
}
```
最后將 SayHello() 改為記錄請求者名字,并返回上次請求者的名字。
```go
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
tag, _ := getConnTagFromContext(ctx)
log.Printf("SayHello(), conn tag = (%p)%#v\n", tag, tag)
connsMutex.Lock()
defer connsMutex.Unlock()
prev := conns[tag]
conns[tag] = in.Name
return &pb.HelloReply{Message: fmt.Sprintf("Hello '%s' (prev '%s')", in.Name, prev)}, nil
}
```
測試多個客戶端連接,可以看到每個客戶端有自己的狀態(tài),互不影響。
```
E:\Git\grpc-go\examples\helloworld (master)
λ go run greeter_server/main.go
2017/12/25 18:39:03 start
2017/12/25 18:39:11 begin conn, tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}, now connections = 1
2017/12/25 18:39:11 SayHello(), conn tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}
2017/12/25 18:39:13 SayHello(), conn tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}
2017/12/25 18:39:13 begin conn, tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}, now connections = 2
2017/12/25 18:39:13 SayHello(), conn tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}
2017/12/25 18:39:15 SayHello(), conn tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}
2017/12/25 18:39:15 SayHello(), conn tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}
2017/12/25 18:39:17 SayHello(), conn tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}
2017/12/25 18:39:17 SayHello(), conn tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}
2017/12/25 18:39:19 end conn, tag = (0xc042182040)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0420818f0), LocalAddr:(*net.TCPAddr)(0xc0420818c0)}, now connections = 1
2017/12/25 18:39:19 SayHello(), conn tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}
2017/12/25 18:39:21 end conn, tag = (0xc0421ae200)&stats.ConnTagInfo{RemoteAddr:(*net.TCPAddr)(0xc0421de060), LocalAddr:(*net.TCPAddr)(0xc0421de030)}, now connections = 0
```
posted on 2017-12-25 19:00
金慶
閱讀(1287)
評論(0)
編輯
收藏
引用
所屬分類:
9. 其它
只有注冊用戶
登錄
后才能發(fā)表評論。
【推薦】100%開源!大型工業(yè)跨平臺軟件C++源碼提供,建模,組態(tài)!
相關文章:
TortoiseGit is OK but GitExtensions fails
DeathVoteExpirationTimeout in Orleans
How to delete local branches of GitExtension
Clustering provider in Orleans
Why Orleans' actor is virutal
What comes after microservice?
Rust Deref coercion example
Rust Error Return Check Policy
Rust visibility
Why does Rust check borrow even in single thread
網(wǎng)站導航:
博客園
IT新聞
BlogJava
博問
Chat2DB
管理
Powered by:
C++博客
Copyright © 金慶
久久这里只精品国产99热
|
久久久99精品成人片中文字幕
|
久久久久久久精品成人热色戒
|
精品久久久久久亚洲精品
|
久久久精品人妻一区二区三区四
|
久久久久四虎国产精品
|
亚洲性久久久影院
|
国产V综合V亚洲欧美久久
|
久久精品亚洲精品国产欧美
|
久久综合给合久久狠狠狠97色
|
中文字幕亚洲综合久久2
|
亚洲欧美日韩中文久久
|
中文精品99久久国产
|
99久久精品这里只有精品
|
亚洲?V乱码久久精品蜜桃
|
人妻久久久一区二区三区
|
国产精品久久久久久久久久免费
|
伊人久久大香线蕉av不变影院
|
久久久久亚洲AV成人网人人网站
|
国产午夜电影久久
|
日韩精品久久无码人妻中文字幕
|
久久精品成人影院
|
99久久亚洲综合精品网站
|
天天躁日日躁狠狠久久
|
亚洲精品高清一二区久久
|
国产精品九九久久精品女同亚洲欧美日韩综合区
|
久久久亚洲AV波多野结衣
|
国产成人精品久久一区二区三区av
|
国产免费久久久久久无码
|
久久久久久国产精品无码超碰
|
久久精品无码一区二区WWW
|
国产成人久久精品二区三区
|
99久久国产热无码精品免费
|
韩国免费A级毛片久久
|
伊人久久综合成人网
|
国产偷久久久精品专区
|
久久91精品国产91久
|
亚洲精品无码专区久久久
|
久久亚洲欧美国产精品
|
久久精品www人人爽人人
|
久久久久久国产精品无码超碰
|