kolinfluence
commented
6 months ago @panjf2000 are these related? https://github.com/panjf2000/gnet/pull/565 remarked here.
not sure if u have seen this repo
https://github.com/luyu6056/tls
https://github.com/luyu6056/gnet
even the http2 is working but i cant seem to get so-reuseport to work. no idea why even when i set it to true.honestly, if i can get luyu6056's tls to work with so reuseport, i'll be contented with the older version use.
@panjf2000 should we wait for the tls on gnet? been waiting for this feature for years. but i'm not rushing u. i understand it's insane amount of work.
p.s. : i got it "working" with tls here but not with the soreuseport option... need soreuseport. can see if i can use it now on the older version?
tlsserver.go (cannot run it twice even with soreuseport option enabled)
package main
import (
"log"
"time"
//"github.com/panjf2000/gnet"
"github.com/kolinfluence/gnet"
"github.com/luyu6056/tls"
)
type echoServer struct {
*gnet.EventServer
}
func (es *echoServer) OnInitComplete(s gnet.Server) (action gnet.Action) {
log.Printf("Echo server started on %s (loops: %d)", s.Addr, s.NumEventLoop)
return
}
func (es *echoServer) React(frame []byte, c gnet.Conn) (action gnet.Action) {
// Echo the incoming data back to the client
c.AsyncWrite(frame)
return
}
func main() {
// Create TLS configuration using certificates
tlsConfig := &tls.Config{
Certificates: make([]tls.Certificate, 1),
PreferServerCipherSuites: true,
MinVersion: tls.VersionTLS12,
}
// Load server certificate and private key
var err error
tlsConfig.Certificates[0], err = tls.LoadX509KeyPair("./cert.pem", "./key.pem")
if err != nil {
log.Fatalf("Failed to load key pair: %v", err)
}
// Configure server options
options := []gnet.Option{
gnet.WithTCPKeepAlive(time.Minute * 5),
gnet.WithTls(tlsConfig),
gnet.WithReusePort(true),
//gnet.WithMulticore(true),
}
// Start the server
log.Fatal(gnet.Serve(new(echoServer), "tcp://:8443", options...))
}
tlsclient.go
package main
import (
"bufio"
"crypto/tls"
"fmt"
"log"
"time"
)
func main() {
// Connect to the server with TLS
conf := &tls.Config{
InsecureSkipVerify: true, // Use this for testing with self-signed certs
}
conn, err := tls.Dial("tcp", "localhost:8443", conf)
if err != nil {
log.Fatalf("Failed to connect to server: %v", err)
}
defer conn.Close()
fmt.Println("Connected to server.")
// Create a reader to read responses from the server
reader := bufio.NewReader(conn)
// Variables for counting requests and responses
var requestsSent int
var responsesReceived int
// Start a ticker to display req/s every second
ticker := time.NewTicker(1 * time.Second)
go func() {
for range ticker.C {
fmt.Printf("Requests sent: %d, Responses received: %d\n", requestsSent, responsesReceived)
// Reset counters
requestsSent = 0
responsesReceived = 0
}
}()
// Loop indefinitely
for {
// Send "hello" to the server
_, err := conn.Write([]byte("hello\n"))
if err != nil {
log.Fatalf("Failed to write to server: %v", err)
}
requestsSent++
// Read the server's response
data, err := reader.ReadString('\n')
if err != nil {
log.Fatalf("Failed to read from server: %v", err)
}
responsesReceived++
fmt.Printf("data = %s\n",data)
}
}
panjf2000
References