Redeo 是用于构建与 redis 协议兼容的 TCP 服务器/服务的高性能框架。
这个仓库被组织成多个组成部分：
- root 包包含构建 redis 协议兼容的高性能服务器的框架
- resp 实现了用于处理 RESP（REdis 序列化协议）、客户端和服务器端的低级基元。它包含读者和作者读/写请求和响应的基本包装器
- 客户端包含一个极简的池化客户端
有关完整文档和示例，请参阅各个包和官方 API 文档：https : //godoc.org/github.com/bsm/redeo。
例子
带有两个命令的简单服务器示例：
package main
import (
"net"
"github.com/bsm/redeo"
)
func main() {
srv := redeo.NewServer(nil)
// Define handlers
srv.HandleFunc("ping", func(w resp.ResponseWriter, _ *resp.Command) {
w.AppendInlineString("PONG")
})
srv.HandleFunc("info", func(w resp.ResponseWriter, _ *resp.Command) {
w.AppendBulkString(srv.Info().String())
})
// More handlers; demo usage of redeo.WrapperFunc
srv.Handle("echo", redeo.WrapperFunc(func(c *resp.Command) interface{} {
if c.ArgN() != 1 {
return redeo.ErrWrongNumberOfArgs(c.Name)
}
return c.Arg(0)
}))
// Open a new listener
lis, err := net.Listen("tcp", ":9736")
if err != nil {
panic(err)
}
defer lis.Close()
// Start serving (blocking)
srv.Serve(lis)
}
func main() {
mu := sync.RWMutex{}
data := make(map[string]string)
srv := redeo.NewServer(nil)
srv.HandleFunc("set", func(w resp.ResponseWriter, c *resp.Command) {
if c.ArgN() != 2 {
w.AppendError(redeo.WrongNumberOfArgs(c.Name))
return
}
key := c.Arg(0).String()
val := c.Arg(1).String()
mu.Lock()
data[key] = val
mu.Unlock()
w.AppendInt(1)
})
srv.HandleFunc("get", func(w resp.ResponseWriter, c *resp.Command) {
if c.ArgN() != 1 {
w.AppendError(redeo.WrongNumberOfArgs(c.Name))
return
}
key := c.Arg(0).String()
mu.RLock()
val, ok := data[key]
mu.RUnlock()
if ok {
w.AppendBulkString(val)
return
}
w.AppendNil()
})
}
func main() {
mu := sync.RWMutex{}
data := make(map[string]string)
srv := redeo.NewServer(nil)
srv.Handle("set", redeo.WrapperFunc(func(c *resp.Command) interface{} {
if c.ArgN() != 2 {
return redeo.ErrWrongNumberOfArgs(c.Name)
}
key := c.Arg(0).String()
val := c.Arg(1).String()
mu.Lock()
data[key] = val
mu.Unlock()
return 1
}))
srv.Handle("get", redeo.WrapperFunc(func(c *resp.Command) interface{} {
if c.ArgN() != 1 {
return redeo.ErrWrongNumberOfArgs(c.Name)
}
key := c.Arg(0).String()
mu.RLock()
val, ok := data[key]
mu.RUnlock()
if ok {
return val
}
return nil
}))
}
-
imi v1.0.13 版本新增了一个 Swoole\Coroutine\Http\Server 实现的协程服务器。需要 Swoole 4.4+ 才可使用该特性。 该特性是可选的，不影响以前使用的服务器模式。 使用协程服务器特性，依靠 Linux 系统的端口重用机制，系统级的负载均衡，可以让你的多进程 Http 服务处理请求的能力得到提升。 使用 ab，本机->虚拟机（双核+2进程）压测Hello
-
问题 你想实现一个服务器，通过TCP协议和客户端通信。 解决方案 创建一个TCP服务器的一个简单方法是使用 socketserver 库。例如，下面是一个简单的应答服务器： from socketserver import BaseRequestHandler, TCPServer class EchoHandler(BaseRequestHandler): def handle(sel
-
Even in the future, nothing works! — Spaceballs 一切迟早都会发生故障。高可用服务就是指当一个主机或网络线路失效时仍旧能够提供服务。 高可用性的主要技术就是冗余，另外，这个问题的解决就是以投放更多硬件设备而著称的。 虽然最终肯定会有单独的一台服务器失效，但是两台服务器同时失效的概率是不太高的， 这对大多数的应用程序提供了一个良好的冗余水平。 最简单的方
-
本文向大家介绍Node.js创建Web、TCP服务器，包括了Node.js创建Web、TCP服务器的使用技巧和注意事项，需要的朋友参考一下 使用http模块创建Web服务器 Web服务器的功能： 接受HTTP请求（GET、POST、DELETE、PUT、PATCH） 处理HTTP请求（自己处理，或请求别的程序处理） 做出响应（返回页面、文件、各类数据等） 常见的Web服务器架构： Nginx、Ap
-
本文向大家介绍Nodejs创建TCP服务器 - king0222，包括了Nodejs创建TCP服务器 - king0222的使用技巧和注意事项，需要的朋友参考一下 1.Nodejs提供了net模块给我们，所以我们创建TCP服务器很简单： 通过var server = require('net').createServer();这行代码我们可以得到tcp服务器对象的引用。 server对象具注册了以
-
大家好， 我试图找出如何基于Wildfly中运行的模块（war）移动我当前的系统架构。现在所有的基础资源都放在JNDI树中，比如数据源、JMS等等。。。我的项目框架是Spring 4和family，它允许我查找这些资源和其他内容。 我的目标是使用Spring Boot和Spring Cloud Netflix创建一个微服务架构，其中每一个WAR都是一个通过总线服务集成的新的独立应用程序。 但我的疑