dpsx99068 2017-10-11 19:50
浏览 62
已采纳

使用websockets Golang将更改推送到客户端

I have been trying to push changes done on server side using websockets in Golang.

I have achived what i wanted by this code

Server side code:

package main

import (
   "golang.org/x/net/websocket"
   "fmt"
   "net/http"
   "os"
   "bufio"
)

type chat struct {
    message string
}

func (ms *chat) Echo(ws *websocket.Conn) {
    var reply string
    for {
         if reply !=  ms.message {
         websocket.Message.Send(ws, ms.message)
         }
         websocket.Message.Receive(ws, reply)
    }
}

func NewMessage(s *string){
   reader := bufio.NewReader(os.Stdin)
   for {
       fmt.Print("Enter text: ")
       *s, _ = reader.ReadString('
')
       }
   }

func main() {
   myString := chat{"Welcome"}
   go NewMessage(&myString.message)
   http.Handle("/", websocket.Handler(myString.Echo))
   http.ListenAndServe(":1234", nil)
}

Client side code:

<html>
<body>
<script type="text/javascript">
    var exampleSocket = new WebSocket("ws://127.0.0.1:1234");

    exampleSocket.onopen = function (event) {
    console.log("connected");
    };

    exampleSocket.onmessage = function (event) {
        console.log(event.data);
        exampleSocket.send(event.data)
        document.getElementById("p1").innerHTML = event.data;
    }


</script>
<h1>WebSockets</h1>
<form>
    <p id="p1" value="Hello, world!"/>
</form>

The problem with above code is repeatedly sending ms.message as if reply != ms.message does not work. Simply var reply string value is not being changed by websocket.Message.Receive(ws, reply).

I have tried passing reply as a pointer but it does not update value on the client side dynamically.

Here is how server side would look like after the change:

package main

import (
   "golang.org/x/net/websocket"
   "fmt"
   "net/http"
   "os"
   "bufio"
)

type chat struct {
    message string
}

func (ms *chat) Echo(ws *websocket.Conn) {
    var reply string
    for {
         if reply !=  ms.message {
         websocket.Message.Send(ws, ms.message)
         }
         websocket.Message.Receive(ws, &reply)
    }
}

func NewMessage(s *string){
   reader := bufio.NewReader(os.Stdin)
   for {
       fmt.Print("Enter text: ")
       *s, _ = reader.ReadString('
')
       }
   }

func main() {
   myString := chat{"Welcome"}
   go NewMessage(&myString.message)
   http.Handle("/", websocket.Handler(myString.Echo))
   http.ListenAndServe(":1234", nil)
}

This code does not fit my expectations.

Is it possible to dynamically update string on clients side without sending value multiple times as it is being done in the example number 1?

  • 写回答

1条回答 默认 最新

  • dongtui4038 2017-10-12 08:25
    关注

    Simply putting websocket.Message.Receive in the if statement fixes the problem.

    package main
    
    import (
       "golang.org/x/net/websocket"
       "fmt"
       "net/http"
       "os"
       "bufio"
    )
    
    type chat struct {
       message string
    }
    
    func (ms *chat) Echo(ws *websocket.Conn) {
       var reply string
          for {
             if reply !=  ms.message {
                websocket.Message.Send(ws, ms.message)
                websocket.Message.Receive(ws, &reply)
             }
    
          }
    }
    
    func NewMessage(s *string){
    reader := bufio.NewReader(os.Stdin)
    for {
       fmt.Print("Enter text: ")
       *s, _ = reader.ReadString('
    ')
      }
    }
    
    func main() {
       myString := chat{"Welcome"}
       go NewMessage(&myString.message)
       http.Handle("/", websocket.Handler(myString.Echo))
       http.ListenAndServe(":1234", nil)
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥30 关于#r语言#的问题:如何对R语言中mfgarch包中构建的garch-midas模型进行样本内长期波动率预测和样本外长期波动率预测
  • ¥15 ETLCloud 处理json多层级问题
  • ¥15 matlab中使用gurobi时报错
  • ¥15 这个主板怎么能扩出一两个sata口
  • ¥15 不是,这到底错哪儿了😭
  • ¥15 2020长安杯与连接网探
  • ¥15 关于#matlab#的问题:在模糊控制器中选出线路信息,在simulink中根据线路信息生成速度时间目标曲线(初速度为20m/s,15秒后减为0的速度时间图像)我想问线路信息是什么
  • ¥15 banner广告展示设置多少时间不怎么会消耗用户价值
  • ¥15 可见光定位matlab仿真
  • ¥15 arduino 四自由度机械臂