Compare commits

..

2 Commits
dev ... master

Author SHA1 Message Date
f91f01d6e3 doc(Readme): 新增客户端和服务端打包的说明 2024-11-05 16:39:52 +08:00
5f83552c53 添加 readme.md 2024-11-05 16:35:37 +08:00
7 changed files with 34 additions and 82 deletions

1
.gitignore vendored
View File

@ -1,3 +1,2 @@
yuchat-proxy-server yuchat-proxy-server
go.sum
*.exe *.exe

View File

@ -1,20 +1,13 @@
from docker.yuchat.top/golang:1.21-alpine AS builder from docker.yuchat.top/golang:1.21-alpine AS builder
workdir /app workdir /app
COPY . . COPY . .
RUN echo "nameserver 114.114.114.114" > /etc/resolv.conf RUN go mod tidy && go build -o yuchat-proxy-server server/main.go
RUN apk add --no-cache \
libpcap-dev \
build-base
RUN go mod tidy
RUN go build -o yuchat-proxy-server server/main.go
from docker.yuchat.top/alpine:3.11 from docker.yuchat.top/alpine:3.11
workdir /app workdir /app
expose 8080 expose 8080
RUN echo "nameserver 114.114.114.114" > /etc/resolv.conf
RUN apk add --no-cache libpcap
copy --from=builder /app/yuchat-proxy-server /app/yuchat-proxy-server copy --from=builder /app/yuchat-proxy-server /app/yuchat-proxy-server
entrypoint ["./yuchat-proxy-server"] entrypoint ["./yuchat-proxy-server"]

View File

@ -1,54 +0,0 @@
package eth
import (
"log"
"github.com/google/gopacket"
"github.com/google/gopacket/pcap"
"github.com/gorilla/websocket"
)
const (
interfaceName = "eth0"
)
type Eth struct {
Handle *pcap.Handle
}
func Init() *Eth {
handle, err := pcap.OpenLive(interfaceName, 1600, true, pcap.BlockForever)
if err != nil {
log.Fatal("打开驱动器失败: ", err)
return nil
}
return &Eth{Handle: handle}
}
/**
* 抓取网卡的数据并写入WebSocket
*/
func (eth *Eth) EthernetPacketsToWs(wsConn *websocket.Conn) error {
packetSource := gopacket.NewPacketSource(eth.Handle, eth.Handle.LinkType())
for packet := range packetSource.Packets() {
wsConn.WriteMessage(websocket.BinaryMessage, packet.Data())
}
return nil
}
/**
* 将ws的数据写入网卡
*/
func (eth *Eth) WsToEthernet(wsConn *websocket.Conn) {
for {
_, p, err := wsConn.ReadMessage()
if err != nil {
return
}
err = eth.Handle.WritePacketData(p)
if err != nil {
log.Fatal(err)
}
}
}

5
go.mod
View File

@ -3,8 +3,3 @@ module yuchat-proxy
go 1.21.0 go 1.21.0
require github.com/gorilla/websocket v1.5.3 require github.com/gorilla/websocket v1.5.3
require (
github.com/google/gopacket v1.1.19
golang.org/x/sys v0.0.0-20190412213103-97732733099d // indirect
)

2
go.sum Normal file
View File

@ -0,0 +1,2 @@
github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=

8
readme.md Normal file
View File

@ -0,0 +1,8 @@
# 1. 打包客户端
本地安装golang的环境
执行 `./yuchat-build.bat` 即可打包出exe
# 2. 服务端打包
使用docker拉取代码到linux直接执行 `docker build -t yuchat-proxy-server:0.0.1` 即可打包出docker镜像

View File

@ -4,18 +4,17 @@ import (
"crypto/tls" "crypto/tls"
"fmt" "fmt"
"log" "log"
"net"
"net/http" "net/http"
"yuchat-proxy/common"
"github.com/gorilla/websocket" "github.com/gorilla/websocket"
"yuchat-proxy/eth"
) )
const ( const (
tcpAddress = "172.20.0.1:1080" tcpAddress = "172.20.0.1:1080"
) )
var e = eth.Init()
var upgrader = websocket.Upgrader{ var upgrader = websocket.Upgrader{
CheckOrigin: func(r *http.Request) bool { CheckOrigin: func(r *http.Request) bool {
return true // 允许来自任何来源的连接 return true // 允许来自任何来源的连接
@ -29,17 +28,25 @@ func wsHandler(w http.ResponseWriter, r *http.Request) {
fmt.Println("websocket连接失败:", err) fmt.Println("websocket连接失败:", err)
return return
} }
remoteConn, err := net.Dial("tcp", tcpAddress)
// remoteConn, err := net.Dial("tcp", tcpAddress) if err != nil {
// if err != nil { log.Printf("本地服务连接失败 %s: %v", tcpAddress, err)
// log.Printf("本地服务连接失败 %s: %v", tcpAddress, err) return
// return }
// }
fmt.Println("本地服务启动成功", tcpAddress) fmt.Println("本地服务启动成功", tcpAddress)
go e.WsToEthernet(conn)
go e.EthernetPacketsToWs(conn) go common.WsToTcpHandler(remoteConn, conn)
// go common.WsToTcpHandler(remoteConn, conn) go common.TcpToWsHandler(remoteConn, conn)
// go common.TcpToWsHandler(remoteConn, conn) }
// HTTP GET 接口,返回 "Hello, World!"
func helloHandler(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusOK) // 设置状态码为 200 OK
w.Header().Set("Content-Type", "text/plain") // 设置响应内容类型
_, err := w.Write([]byte("Hello, World!"))
if err != nil {
log.Println("Write failed:", err)
}
} }
func main() { func main() {
@ -50,8 +57,10 @@ func main() {
}, },
} }
http.HandleFunc("/ws", wsHandler) http.HandleFunc("/ws", wsHandler)
http.HandleFunc("/hello", helloHandler)
fmt.Println("WebSocket服务已启动地址ws://localhost:8080/ws") fmt.Println("WebSocket服务已启动地址ws://localhost:8080/ws")
if err := server.ListenAndServe(); err != nil { if err := server.ListenAndServe(); err != nil {
log.Fatalf("Server failed: %s", err) log.Fatalf("Server failed: %s", err)
} }
} }