【文件属性】：
文件名称：aeron-go:高效可靠的UDP单播，UDP组播和IPC消息传输-Go端口
文件大小：90KB
文件格式：ZIP
更新时间：2021-05-15 15:17:24
Go
Aeron-go
在Go中实现消息传递客户端。
您可以在找到Aeron的架构，设计和协议
用法
示例订户可以在找到。
示例出版物可在找到。
常见的
使用上下文实例化Aeron：
ctx := aeron . NewContext (). MediaDriverTimeout ( time . Second * 10 )
a := aeron . Connect ( ctx )
订户
创建订阅：
subscription := <- a . AddSubscription ( "aeron:ipc" , 10 )
defer subscription . Close ()
aeron.AddSubscription()返回一个通道，以便用户可以选择阻止等待订阅以向驱动程序注册或进行异步select轮询。
定义消息处理的回调：
handler := func ( buff
【文件预览】：
aeron-go-master
----.gitignore(489B)
----go.mod(319B)
----.travis.yml(35B)
----LICENSE(11KB)
----go.sum(1KB)
----examples()
--------Makefile(330B)
--------ping()
--------basic_publisher()
--------basic_publisher_claim()
--------pong()
--------basic_subscriber()
--------common.go(2KB)
----systests()
--------systest.go(8KB)
----README.md(3KB)
----aeron()
--------image.go(5KB)
--------fragmentassembler.go(3KB)
--------ringbuffer()
--------imagelist.go(1KB)
--------position.go(1KB)
--------clientconductor.go(21KB)
--------logbuffer()
--------flyweight()
--------const_windows.go(795B)
--------atomic()
--------aeron.go(6KB)
--------const_linux.go(789B)
--------util()
--------stat()
--------subscription.go(5KB)
--------command()
--------context.go(4KB)
--------const.go(840B)
--------channeluri.go(4KB)
--------counters()
--------broadcast()
--------publication.go(8KB)
--------idlestrategy()
--------driver()
--------channeluri_test.go(3KB)
--------publication_test.go(6KB)