Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| f814bb7d24 | |||
| aed740c933 |
41
client.go
41
client.go
@@ -6,6 +6,7 @@ package dsrpc
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"crypto/tls"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
@@ -32,6 +33,18 @@ func Put(ctx context.Context, address string, method string, reader io.Reader, b
|
|||||||
return ConnPut(ctx, conn, method, reader, binSize, param, result, auth)
|
return ConnPut(ctx, conn, method, reader, binSize, param, result, auth)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func PutTLS(ctx context.Context, tlsConfig *tls.Config, address string, method string, reader io.Reader, binSize int64, param, result any, auth *Auth) error {
|
||||||
|
var err error
|
||||||
|
|
||||||
|
conn, err := tls.Dial("tcp", address, tlsConfig)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
|
||||||
|
return ConnPut(ctx, conn, method, reader, binSize, param, result, auth)
|
||||||
|
}
|
||||||
|
|
||||||
func ConnPut(ctx context.Context, conn net.Conn, method string, reader io.Reader, binSize int64, param, result any, auth *Auth) error {
|
func ConnPut(ctx context.Context, conn net.Conn, method string, reader io.Reader, binSize int64, param, result any, auth *Auth) error {
|
||||||
var err error
|
var err error
|
||||||
content := CreateContent(conn)
|
content := CreateContent(conn)
|
||||||
@@ -99,6 +112,18 @@ func Get(ctx context.Context, address string, method string, writer io.Writer, p
|
|||||||
return ConnGet(ctx, conn, method, writer, param, result, auth)
|
return ConnGet(ctx, conn, method, writer, param, result, auth)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetTLS(ctx context.Context, tlsConfig *tls.Config, address string, method string, writer io.Writer, param, result any, auth *Auth) error {
|
||||||
|
var err error
|
||||||
|
|
||||||
|
conn, err := tls.Dial("tcp", address, tlsConfig)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
|
||||||
|
return ConnGet(ctx, conn, method, writer, param, result, auth)
|
||||||
|
}
|
||||||
|
|
||||||
func ConnGet(ctx context.Context, conn net.Conn, method string, writer io.Writer, param, result any, auth *Auth) error {
|
func ConnGet(ctx context.Context, conn net.Conn, method string, writer io.Writer, param, result any, auth *Auth) error {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
@@ -161,6 +186,22 @@ func Exec(ctx context.Context, address, method string, param any, result any, au
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ExecTLS(ctx context.Context, tlsConfig *tls.Config, address, method string, param any, result any, auth *Auth) error {
|
||||||
|
var err error
|
||||||
|
|
||||||
|
conn, err := tls.Dial("tcp", address, tlsConfig)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
|
||||||
|
err = ConnExec(ctx, conn, method, param, result, auth)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
func ConnExec(ctx context.Context, conn net.Conn, method string, param any, result any, auth *Auth) error {
|
func ConnExec(ctx context.Context, conn net.Conn, method string, param any, result any, auth *Auth) error {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
|
|||||||
36
server.go
36
server.go
@@ -6,6 +6,7 @@ package dsrpc
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"crypto/tls"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
@@ -94,6 +95,32 @@ func (svc *Service) Listen(address string) error {
|
|||||||
default:
|
default:
|
||||||
}
|
}
|
||||||
svc.wg.Add(1)
|
svc.wg.Add(1)
|
||||||
|
go svc.handleTCPConn(conn, svc.wg)
|
||||||
|
}
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (svc *Service) ListenTLS(address string, tlsConfig *tls.Config) error {
|
||||||
|
var err error
|
||||||
|
logInfo("server listen:", address)
|
||||||
|
|
||||||
|
listener, err := tls.Listen("tcp", address, tlsConfig)
|
||||||
|
if err != nil {
|
||||||
|
err = fmt.Errorf("unable to start listener: %s", err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
for {
|
||||||
|
conn, err := listener.Accept()
|
||||||
|
if err != nil {
|
||||||
|
logError("conn accept err:", err)
|
||||||
|
}
|
||||||
|
select {
|
||||||
|
case <-svc.ctx.Done():
|
||||||
|
return err
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
svc.wg.Add(1)
|
||||||
go svc.handleConn(conn, svc.wg)
|
go svc.handleConn(conn, svc.wg)
|
||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
@@ -116,9 +143,8 @@ func (svc *Service) Stop() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (svc *Service) handleConn(conn *net.TCPConn, wg *sync.WaitGroup) {
|
func (svc *Service) handleTCPConn(conn *net.TCPConn, wg *sync.WaitGroup) {
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
if svc.keepalive {
|
if svc.keepalive {
|
||||||
err = conn.SetKeepAlive(true)
|
err = conn.SetKeepAlive(true)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -133,6 +159,12 @@ func (svc *Service) handleConn(conn *net.TCPConn, wg *sync.WaitGroup) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
svc.handleConn(conn, wg)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (svc *Service) handleConn(conn net.Conn, wg *sync.WaitGroup) {
|
||||||
|
var err error
|
||||||
|
|
||||||
content := CreateContent(conn)
|
content := CreateContent(conn)
|
||||||
|
|
||||||
remoteAddr := conn.RemoteAddr().String()
|
remoteAddr := conn.RemoteAddr().String()
|
||||||
|
|||||||
Reference in New Issue
Block a user