beego与websocker的集成-阿里云开发者社区

开发者社区> 开发与运维> 正文

beego与websocker的集成

简介: 上周刚好遇到这个问题。 周末在家里按网上的方案测试了一下。 希望下周进展顺利~~ URL:   http://blog.csdn.net/u012210379/article/details/72912056     package controllers import (...

上周刚好遇到这个问题。

周末在家里按网上的方案测试了一下。

希望下周进展顺利~~

URL:

 

http://blog.csdn.net/u012210379/article/details/72912056

 

 

package controllers

import (
	"beegows/models"
	"fmt"
	"log"
	"time"

	"github.com/astaxie/beego"
	// "github.com/astaxie/beego/toolbox"
	"github.com/gorilla/websocket"
)

type MyWebSocketController struct {
	beego.Controller
}

var upgrader = websocket.Upgrader{}

func (c *MyWebSocketController) Get() {
	ws, err := upgrader.Upgrade(c.Ctx.ResponseWriter, c.Ctx.Request, nil)
	if err != nil {
		log.Fatal(err)
	}
	//defer ws.Close()
	clients[ws] = true
	/*
		for {
			time.Sleep(time.Second * 3)
			msg := models.Message{Message: "这是向页面发送的数据" + time.Now().Format("2006-01-02 15:04:05")}
			broadcast <- msg
		}
	*/
	for {
		time.Sleep(time.Second * 3)

		var msg models.Message // Read in a new message as JSON and map it to a Message object
		err := ws.ReadJSON(&msg)
		if err != nil {
			log.Printf("页面可能断开啦 ws.ReadJSON error: %v", err)
			delete(clients, ws)
			break
		} else {
			fmt.Println("接受到从页面上反馈回来的信息 ", msg.Message)
		}

		broadcast <- msg
	}
}

  

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章