diff --git a/controllers/event.go b/controllers/event.go
index e6690e6e4..a084b93ac 100644
--- a/controllers/event.go
+++ b/controllers/event.go
@@ -1,7 +1,6 @@
 package controllers
 
 import (
-	"fmt"
 	"log"
 	"net/http"
 	"time"
@@ -31,7 +30,7 @@ type EventController struct {
 var clients = make(map[*websocket.Conn]bool)
 
 //广播频道(通道)
-var broadcast = make(chan *model.ImMessageRecord)
+var broadcast = make(chan []*model.ImMessageRecord)
 
 // 配置升级程序(升级为websocket)
 var upgrader = websocket.Upgrader{}
@@ -110,7 +109,6 @@ func (c *EventController) GetWeixinUnlimited() {
 
 // @Title 测试websocket
 // @Description 测试websocket
-// @Param	token			header		string	true	"认证token"
 // @Success 200 {object} controllers.CallResult
 // @Failure 200 {object} controllers.CallResult
 // @router /TestWebsocket [get]
@@ -129,7 +127,6 @@ func (c *EventController) TestWebsocket() {
 		log.Fatal(err)
 	}
 	defer ws.Close()
-	fmt.Println("testrequest", utils.Format4Output(c.Ctx.Request, false))
 	//将当前客户端放入map中
 	clients[ws] = true
 
@@ -137,7 +134,9 @@ func (c *EventController) TestWebsocket() {
 		VendorID: 111111,
 	}
 	// 把消息 写入通道
-	broadcast <- m
+	broadcast <- []*model.ImMessageRecord{
+		m,
+	}
 
 	c.EnableRender = false //Beego不启用渲染
 
@@ -151,7 +150,9 @@ func (c *EventController) TestWebsocket() {
 			break               //结束循环
 		} else {
 			//接受消息 业务逻辑
-			broadcast <- &s
+			broadcast <- []*model.ImMessageRecord{
+				&s,
+			}
 			db := dao.GetDB()
 			dao.WrapAddIDCULDEntity(&s, "")
 			dao.CreateEntity(db, &s)