-
Notifications
You must be signed in to change notification settings - Fork 3
/
typeEvent.go
64 lines (54 loc) · 1.26 KB
/
typeEvent.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
package sseKit
import (
"fmt"
"github.com/gin-contrib/sse"
"github.com/richelieu-yang/chimera/v2/src/urlKit"
"net/http"
)
type Event sse.Event
func (e Event) Push(w http.ResponseWriter) error {
if err := sse.Encode(w, sse.Event(e)); err != nil {
return err
}
// 没有下面这一代码会导致: 前端无法及时收到推送的消息
w.(http.Flusher).Flush()
return nil
}
// MessageEvent 定义SSE事件.
/*
Deprecated: Use sse.Event of github.com/gin-contrib/sse instead.
*/
type MessageEvent struct {
// Id
/*
PS:
(1) 对应前端的 e.lastEventId.
(2) 可以为"".
*/
Id string
// Event
/*
PS:
(1) 对应前端的 e.type.
(2) 可以为""(此时等价于"message")
(3) 如果不是 "message" 的话,前端需要自行添加对应的监听.
*/
Event string
// Data
/*
PS:
(1) 对应前端的 e.data.
(2) 可以为"".
(3) 建议对内容编码下,以防其中有特殊字符(\n等).
*/
Data string
}
// String 实现SSE事件的 String() 方法
func (e MessageEvent) String() string {
/*
对 e.Data 编码1次,以防其中有特殊字符(比如'\n')
!!!: 前端需要手动解码1次
*/
data := urlKit.EncodeURIComponent(e.Data)
return fmt.Sprintf("id: %s\nevent: %s\ndata: %s\n\n", e.Id, e.Event, data)
}