代码拉取完成,页面将自动刷新
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"
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。