加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
此仓库是为了提升国内下载速度的镜像仓库,每日同步一次。 原始仓库: https://github.com/buger/goreplay
克隆/下载
output_ws_test.go 1.61 KB
一键复制 编辑 原始数据 按行查看 历史
package goreplay
import (
"log"
"net/http"
"sync"
"testing"
"github.com/gorilla/websocket"
"github.com/stretchr/testify/assert"
)
func TestWebSocketOutput(t *testing.T) {
wg := new(sync.WaitGroup)
var gotHeader http.Header
wsAddr := startWebsocket(func(data []byte) {
wg.Done()
}, func(header http.Header) {
gotHeader = header
})
input := NewTestInput()
headers := map[string][]string{
"key1": {"value1"},
"key2": {"value2"},
}
output := NewWebSocketOutput(wsAddr, &WebSocketOutputConfig{Workers: 1, Headers: headers})
plugins := &InOutPlugins{
Inputs: []PluginReader{input},
Outputs: []PluginWriter{output},
}
emitter := NewEmitter()
go emitter.Start(plugins, Settings.Middleware)
for i := 0; i < 10; i++ {
wg.Add(1)
input.EmitGET()
}
wg.Wait()
emitter.Close()
if assert.NotNil(t, gotHeader) {
assert.Equal(t, "Basic dXNlcjE=", gotHeader.Get("Authorization"))
for k, values := range headers {
assert.Equal(t, 1, len(values))
assert.Equal(t, values[0], gotHeader.Get(k))
}
}
}
func startWebsocket(cb func([]byte), headercb func(http.Header)) string {
upgrader := websocket.Upgrader{}
http.HandleFunc("/test", func(w http.ResponseWriter, r *http.Request) {
headercb(r.Header)
c, err := upgrader.Upgrade(w, r, nil)
if err != nil {
log.Print("upgrade:", err)
return
}
go func(conn *websocket.Conn) {
defer conn.Close()
for {
_, msg, _ := conn.ReadMessage()
cb(msg)
}
}(c)
})
go func() {
err := http.ListenAndServe("localhost:8081", nil)
if err != nil {
log.Fatal("Can't start:", err)
}
}()
return "ws://user1@localhost:8081/test"
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化