aceld演示项目:IM-System
This commit is contained in:
parent
ba978f98b5
commit
5f80f1ce38
2
bilibili/aceld/IM-System/.gitignore
vendored
Normal file
2
bilibili/aceld/IM-System/.gitignore
vendored
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
/server
|
||||||
|
!.gitignore
|
25
bilibili/aceld/IM-System/README.md
Normal file
25
bilibili/aceld/IM-System/README.md
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
# golang即时通信系统
|
||||||
|
|
||||||
|
## 0.1版本
|
||||||
|
|
||||||
|
基本server构建
|
||||||
|
|
||||||
|
编译
|
||||||
|
|
||||||
|
```sh
|
||||||
|
go build -o server main.go server.go
|
||||||
|
```
|
||||||
|
|
||||||
|
启动
|
||||||
|
|
||||||
|
```sh
|
||||||
|
./server
|
||||||
|
```
|
||||||
|
|
||||||
|
客户端验证(在另一个终端上)
|
||||||
|
|
||||||
|
```sh
|
||||||
|
nc 127.0.0.1 8888
|
||||||
|
```
|
||||||
|
|
||||||
|
效果:在server端可以看到连接建立成功
|
3
bilibili/aceld/IM-System/go.mod
Normal file
3
bilibili/aceld/IM-System/go.mod
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
module IM-System
|
||||||
|
|
||||||
|
go 1.23.0
|
6
bilibili/aceld/IM-System/main.go
Normal file
6
bilibili/aceld/IM-System/main.go
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
server := NewServer("127.0.0.1", 8888)
|
||||||
|
server.Start()
|
||||||
|
}
|
49
bilibili/aceld/IM-System/server.go
Normal file
49
bilibili/aceld/IM-System/server.go
Normal file
@ -0,0 +1,49 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"net"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Server struct {
|
||||||
|
Ip string
|
||||||
|
Port int
|
||||||
|
}
|
||||||
|
|
||||||
|
// 创建一个server的接口
|
||||||
|
func NewServer(ip string, port int) *Server {
|
||||||
|
server := &Server{
|
||||||
|
Ip: ip,
|
||||||
|
Port: port,
|
||||||
|
}
|
||||||
|
return server
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *Server) Handler(conn net.Conn) {
|
||||||
|
// ...当前链接的业务
|
||||||
|
fmt.Println("连接建立成功")
|
||||||
|
}
|
||||||
|
|
||||||
|
// 启动服务器的接口
|
||||||
|
func (this *Server) Start() {
|
||||||
|
// socket listen
|
||||||
|
listener, err := net.Listen("tcp", fmt.Sprintf("%s:%d", this.Ip, this.Port))
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("net.Listen err:", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
// close listen socket
|
||||||
|
defer listener.Close()
|
||||||
|
|
||||||
|
for {
|
||||||
|
// accept
|
||||||
|
conn, err := listener.Accept()
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("listener accept err:", err)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
// do handler
|
||||||
|
go this.Handler(conn)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user