# qubit-rpc

**Repository Path**: molast/qubit-rpc

## Basic Information

- **Project Name**: qubit-rpc
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-03-04
- **Last Updated**: 2025-03-04

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README


## 用法

### 服务器初始化

```go
s := wkrpc.New("tcp://127.0.0.1:10000")
defer s.Stop()

err = s.Start()
```

### 客户端初始化

```go
cli := client.New("tcp://127.0.0.1:10000")
defer cli.Stop()

err = cli.Start()
```

### 用法一: Request/Response

server

```go
s.Route("/hi", func(c *wkrpc.Context) {
	c.Write([]byte("reply"))
})
```

client 

```go
resp,_ := cli.Request("/hi", []byte("hi"))

fmt.Println(string(resp.Body)) // reply
```

### 用法二: Send/Receive

server

```go
s.OnMessage(func(conn gnet.Conn, m *proto.Message) {
    fmt.Println(string(msg.Body)) // hi
})
```

client

```go
err = cli.Send(&proto.Message{
	MsgType: 1,
	Content: []byte("hi"),
})
```