文件名称：aeron-go:高效可靠的UDP单播，UDP组播和IPC消息传输-Go端口
文件大小：90KB
文件格式：ZIP
更新时间：2024-06-04 09:04:04
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)