From fef46f3a0be292fba4fe8449320e33e829b6b67d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E5=BE=B7=E6=BB=A1?= <go_developer@163.com>
Date: Sun, 28 Mar 2021 17:21:47 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=AF=B9=E5=BD=93=E5=89=8D?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF=E7=9A=84?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 example/server.go  |  3 +++
 message/message.go | 24 ++++++++++++++++++++++++
 2 files changed, 27 insertions(+)
 create mode 100644 message/message.go

diff --git a/example/server.go b/example/server.go
index e25d586..5642057 100644
--- a/example/server.go
+++ b/example/server.go
@@ -10,6 +10,8 @@ package main
 import (
 	"fmt"
 
+	"github.com/go-developer/websocket/message"
+
 	"github.com/go-developer/websocket"
 	"github.com/go-developer/websocket/abstract"
 	"github.com/go-developer/websocket/context"
@@ -24,6 +26,7 @@ type Example struct {
 
 func (e Example) Connect(ctx *context.WSContext) {
 	fmt.Println("建立连接成功")
+	message.Response(ctx, map[string]interface{}{"say": "hello world!"})
 }
 
 func (e Example) Disconnect(ctx *context.WSContext) {
diff --git a/message/message.go b/message/message.go
new file mode 100644
index 0000000..6698fe9
--- /dev/null
+++ b/message/message.go
@@ -0,0 +1,24 @@
+// Package message ...
+//
+// Description : 消息相关操作
+//
+// Author : go_developer@163.com<张德满>
+//
+// Date : 2021-03-28 5:15 下午
+package message
+
+import (
+	"encoding/json"
+
+	"github.com/go-developer/websocket/context"
+)
+
+// Response 对当前连接的相关行为做出响应
+//
+// Author : go_developer@163.com<张德满>
+//
+// Date : 5:17 下午 2021/3/28
+func Response(wsCtx *context.WSContext, data map[string]interface{}) error {
+	byteData, _ := json.Marshal(data)
+	return wsCtx.Session.Write(byteData)
+}