websocket聊天记录保存在本地，请教一下大神_course

最近做一个聊天的本地APP，通过h5的websocket来实现，聊天功能已经实现，但是怎么把聊天记录保存在本地?

Gorilla WebSocket与golang.org/x/net/websocket的比较_course

<div class="post-text" itemprop="text"> <p>According <a href="https://github.com/gorilla/websocket#gorilla-websocket-compared-with-other-packages" rel="nofollow">Gorilla Websockets Project</a> it is not possible to send pings and pongs using <strong>golang.org/x/net/websocket</strong>. At the same time, the following is on the project page of <a href="http://godoc.org/golang.org/x/net/websocket" rel="nofollow">golang.org/x/net/websocket</a>:</p> <blockquote> <p>Package websocket implements a client and server for the WebSocket protocol as specified in RFC 6455.</p> </blockquote> <p>I am a little confused. <strong>golang.org/x/net/websocket</strong> implements RFC 6455 but can not send control frames (cancel, ping, pong) although this is specified in <a href="http://tools.ietf.org/html/rfc6455#section-5.5" rel="nofollow">RFC 6455 - Section Control Frames</a></p> <p>So what will happen if I use <strong>golang.org/x/net/websocket</strong> package. Will the connection abort after a timeout? In other words, how is it ensured here that the connection does not break off.</p> </div>

使用Golang的gorilla / websocket软件包的Websocket连接断开_course

<div class="post-text" itemprop="text"> <p>I'm attempting to port a NodeJS script that establishes and maintains a Websocket connection to a third-party server to Go using the <a href="https://github.com/gorilla/websocket" rel="nofollow noreferrer">gorilla/websocket</a> package. In the <a href="https://gist.github.com/anonymous/7c169e995d13a943d3f494c88cac7a17" rel="nofollow noreferrer">Node script</a>, a pong is received following a ping, and the connection is kept alive indefinitely. In the <a href="https://gist.github.com/anonymous/69b8dca0172803fccb45dfeb5d310133" rel="nofollow noreferrer">Go script</a>, ping/pong works but the connection is dropped by the server after about 30 seconds. </p> <p>I suspect that the pings that are sent using the Go websocket package are malformed, but I can't pinpoint the cause of this. Comparing the captured, encrypted network traffic while running these programs shows no difference in the response length of the TCP requests and responses, so this may not be the issue. Any help would be greatly appreciated!</p> <p><strong>websocket.js</strong></p> <pre><code>#!/usr/bin/env node // npm install websocket@1.0.25 --save const WebSocketClient = require('websocket').client; const client = new WebSocketClient(); let lastPing = new Date().getTime(); client.on('connectFailed', function(error) { console.log('Connect Error: ' + error.toString()); }); client.on('connect', function(connection) { console.log('Connected to Server...'); connection.on('error', function(error) { console.log("Connection Error: " + error.toString()); }); connection.on('close', function() { console.log('Connection Closed'); }); connection.on('message', function(message) { if (message.type === 'utf8') { console.log(message.utf8Data); } }); connection.on('pong', function(){ console.log('[pingpong] response took', (new Date().getTime() - lastPing) + 'ms'); }) function send(message) { if (connection.connected) { connection.sendUTF(message); } } // Send a ping every 10s // to keep the connection live setInterval(function(){ lastPing = new Date().getTime(); connection.ping(); }, 10000); }); client.connect('wss://ws.radarrelay.com/0x/v0/ws'); </code></pre> <p><strong>websocket.go</strong></p> <pre><code>package main import ( "flag" "log" "os" "os/signal" "time" "github.com/gorilla/websocket" ) var addr = "wss://api.radarrelay.com/0x/v0/ws" func main() { flag.Parse() log.SetFlags(0) timeoutDuration := 2 * time.Minute interrupt := make(chan os.Signal, 1) signal.Notify(interrupt, os.Interrupt) c, _, err := websocket.DefaultDialer.Dial(addr, nil) if err != nil { log.Fatal("dial:", err) } else { log.Println("Connected to server") } c.SetPongHandler(func(str string) error { log.Println("pong received", str) return nil }) defer c.Close() done := make(chan struct{}) go func() { defer c.Close() defer close(done) for { c.SetReadDeadline(time.Now().Add(timeoutDuration)) _, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) return } if len(message) &gt;= 2 { message = message[2:] } log.Printf("recv: %s", message) } }() ticker := time.NewTicker(10 * time.Second) defer ticker.Stop() for { select { case _ = &lt;-ticker.C: err := c.WriteMessage(websocket.PingMessage, []byte{}) if err != nil { log.Println("write:", err) return } else { log.Println("ping sent") } case &lt;-interrupt: log.Println("interrupt") // To cleanly close a connection, a client should send a close // frame and wait for the server to close the connection. err := c.WriteMessage( websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, "")) if err != nil { log.Println("write close:", err) return } select { case &lt;-done: case &lt;-time.After(time.Second): } c.Close() return } } } </code></pre> </div>

使用Golang扩展WebSocket连接_course

<div class="post-text" itemprop="text"> <pre><code> func handleConn(w http.ResponseWriter, r *http.Request) { ws, err := upgrader.Upgrade(w, r, nil) if err != nil { if _, ok := err.(websocket.HandshakeError); !ok { log.Println(err) } return } go writer(ws) reader(r, ws) } func main() { http.HandleFunc("/", handleConn) } </code></pre> <p>I am trying to build a high scaling websocket server using golang. Since there is lack of support in native go websocket package, i am using <a href="https://github.com/gorilla/websocket" rel="nofollow noreferrer">https://github.com/gorilla/websocket</a>. </p> <p>For every connection, a goroutine will be spawned to take care of writes to it. For scaling huge number of connections. Let's say if I have 1M concurrent connections then there should be 1M goroutines will be running on the server.</p> <p><strong>Hardware Specification:</strong></p> <p>16 GB Ram</p> <p>4 Core CPU</p> <p>2.5 GHz Intel Core i5</p> <p>will it work for large number of connections without affecting the performance?</p> </div>

Gorilla Websocket-读取错误：在失败的Websocket连接上重复读取_course

<div class="post-text" itemprop="text"> <p>Using the gorilla websocket api for go, how do i know if a client is still connected?</p> <p>What Im trying with now is: </p> <pre><code>func Listen(ws *websocket.Conn) { connTimeout := 3 timeLastSent := time.Now().Second() for ((timeLastSent + connTimeout) % 60) != time.Now().Second() { msg := Message{} err := ws.ReadJSON(&amp;msg) if err == websocket.ErrCloseSent { break } else if err != nil { continue } //Message recived EventMessage &lt;- msg timeLastSent = time.Now().Second() } //Connection timed out. return } </code></pre> <p>But this results in the error <code>repeated read on failed websocket connection</code>. </p> <p>Ive been looking into using <code>ws.SetReadDeadline(t)</code>, but Ive no idea of either how to use it nor if its even the thing Im looking for.</p> <p>How should i go about this? </p> </div>

如何为wss连接创建websocket？_course

<div class="post-text" itemprop="text"> <p>I have the following code for connection to my websocket, but the problem is when the domain has an SSL certificate as it is my case, when I make the connection with ws everything works perfectly, but when I put the wss I get this error </p> <blockquote> <p>Error in connection establishment: net::ERR_SSL_PROTOCOL_ERROR</p> </blockquote> <p>index.js</p> <pre><code>&lt;script type="text/javascript"&gt; $(document).ready(function(){ //create a new WebSocket object. var wsUri = "wss://dominio.com:9001/socket.php"; websocket = new WebSocket(wsUri); websocket.onopen = function(ev) { // connection is open var preg = { id: 303, historial: { titulo: 'Conexion al sistema', url: window.location.href } }; //convert and send data to server websocket.send(JSON.stringify(preg)); } //#### Message received from server? websocket.onmessage = function(ev) { var msg = JSON.parse(ev.data); //PHP sends Json data //alert(msg.user); console.log(JSON.stringify(msg)); if(msg.conexion){ var preg = { id: 303, estado: 1 }; //convert and send data to server websocket.send(JSON.stringify(preg)); }else{ //$("#res").load("cargar.php",{bloque:'session',array:msg}); } /* if(msg.user == 'system'){ //console.log(umsg); //preg=JSON.parse(umsg); var preg = { id: &lt;?=$_GET['u']?&gt;, recurso: msg.recurso, estado: msg.estado, historial: { titulo: 'Conexion al sistema', url: window.location.href } }; //convert and send data to server websocket.send(JSON.stringify(preg)); //$('#message_box').append("&lt;div class=\"system_msg\"&gt;"+umsg+"&lt;/div&gt;"); }*/ }; websocket.onerror = function(ev){}; websocket.onclose = function(ev){}; }); &lt;/script&gt; </code></pre> <p>and this is my php socket.php</p> <pre><code>&lt;?php $host = '0.0.0.0'; //host $port = '9001'; //port $null = NULL; //null var $json_general=array(); //Create TCP/IP sream socket $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //reuseable port socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1); //bind socket to specified host socket_bind($socket, 0, $port); //$socket = stream_socket_client("ssl://localhost:9001", $errno, $errstr); //listen to port socket_listen($socket); //create &amp; add listning socket to the list $clients = array($socket); //start endless loop, so that our script doesn't stop while (true) { //manage multipal connections $changed = $clients; //returns the socket resources in $changed array socket_select($changed, $null, $null, 0, 10); //check for new socket if (in_array($socket, $changed)) { $socket_new = socket_accept($socket); //accpet new socket $clients[] = $socket_new; //add socket to client array $header = socket_read($socket_new, 1024); //read data sent by the socket perform_handshaking($header, $socket_new, $host, $port); //perform websocket handshake socket_getpeername($socket_new, $ip); //get ip address of connected socket //$response = mask(json_encode(array('user'=&gt;'system','tipo'=&gt;'0', 'destino'=&gt;'0', 'categoria'=&gt;'0', 'descripcion'=&gt;'', 'estado'=&gt;'Conectado','datos'=&gt;array('ip'=&gt;$ip, 'recurso'=&gt;''.$socket_new)))); $response = mask(json_encode(array('user'=&gt;'system', 'estado'=&gt;1,'ip'=&gt;$ip, 'recurso'=&gt;''.str_replace("Resource id #","",$socket_new)))); //$response = mask(json_encode(array('type'=&gt;'system', 'message'=&gt;$ip.' conectado'.$socket_new))); //prepare json data send_message($response); //notify all users about new connection //make room for new socket $found_socket = array_search($socket, $changed); unset($changed[$found_socket]); } //loop through all connected sockets foreach ($changed as $changed_socket) { //check for any incoming data while(socket_recv($changed_socket, $buf, 1024, 0) &gt;= 1) { $received_text = unmask($buf); //unmask data $tst_msg = json_decode($received_text, true); //json decode /*if(isset($tst_msg['conexion'])){ $pre=array(); foreach($json_general as $id =&gt; $dat){ $pre[$id]=array(); $pre[$id]['estado']=0; $pre[$id]['historial']=$dat['historial']; } $json_general=$pre; $response_text = mask(json_encode($tst_msg)); send_message($response_text); }*/ if(isset($tst_msg['id'])){ if(isset($json_general[$tst_msg['id']])){ //$json_general[$tst_msg['id']]=array(); if(isset($tst_msg['historial'])){ if(isset($json_general[$tst_msg['id']]['historial'])){ $q=count($json_general[$tst_msg['id']]['historial']); }else{ $json_general[$tst_msg['id']]['historial']=array(); $q=0; } $json_general[$tst_msg['id']]['historial'][$q]=array(); $json_general[$tst_msg['id']]['historial'][$q]=$tst_msg['historial']; $json_general[$tst_msg['id']]['historial'][$q]['fecha']=date("Y-m-d H:i:s"); } if($json_general[$tst_msg['id']]['estado']){ $json_general[$tst_msg['id']]['estado']=$tst_msg['estado']; } }else{ $json_general[$tst_msg['id']]=array(); $json_general[$tst_msg['id']]['historial'][0]=$tst_msg['historial']; $json_general[$tst_msg['id']]['historial'][0]['fecha']=date("Y-m-d H:i:s"); } if(isset($socket_new)){ $json_general[$tst_msg['id']]['recurso']=str_replace("Resource id #","",$socket_new); $json_general[$tst_msg['id']]['estado']=1; } } //prepare data to be sent to client $response_text = mask(json_encode($json_general)); //$response_text = mask(json_encode(array('type'=&gt;'usermsg', 'typem'=&gt;$user_type, 'name'=&gt;$user_name, 'message'=&gt;$user_message, 'color'=&gt;$user_color, 'tipo'=&gt;$tipo, 'entrada'=&gt;$entrada))); send_message($response_text); //send data break 2; //exist this loop } $buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ); if ($buf === false) { // check disconnected client // remove client for $clients array $found_socket = array_search($changed_socket, $clients); socket_getpeername($changed_socket, $ip); unset($clients[$found_socket]); //notify all users about disconnected connection //$response = mask(json_encode(array('user'=&gt;'system','tipo'=&gt;'0', 'destino'=&gt;'0', 'categoria'=&gt;'0', 'descripcion'=&gt;'', 'estado'=&gt;'Desconectado','datos'=&gt;array('ip'=&gt;$ip, 'recurso'=&gt;''.$socket_new)))); $response = mask(json_encode(array('user'=&gt;'system', 'estado'=&gt;0,'ip'=&gt;$ip, 'recurso'=&gt;''.str_replace("Resource id #","",$socket_new)))); foreach($json_general as $key =&gt; $dato){ if($dato['recurso']==str_replace("Resource id #","",$socket_new)){ //$json_general[$key]['estado']=0; } } //$response = mask(json_encode(array('type'=&gt;'system', 'message'=&gt;$ip.' desconectado'))); send_message($response); //envio de datos generales //$response_text = mask(json_encode($json_general)); $pre=array(); foreach($json_general as $id =&gt; $dat){ $pre[$id]=array(); $pre[$id]['estado']=0; $pre[$id]['historial']=$dat['historial']; } $json_general=$pre; $response_text = mask('{"conexion":1}'); send_message($response_text); } } } // close the listening socket socket_close($socket); function send_message($msg){ global $clients; foreach($clients as $changed_socket){ @socket_write($changed_socket,$msg,strlen($msg)); } return true; } //Unmask incoming framed message function unmask($text) { $length = ord($text[1]) &amp; 127; if($length == 126) { $masks = substr($text, 4, 4); $data = substr($text, 8); } elseif($length == 127) { $masks = substr($text, 10, 4); $data = substr($text, 14); } else { $masks = substr($text, 2, 4); $data = substr($text, 6); } $text = ""; for ($i = 0; $i &lt; strlen($data); ++$i) { $text .= $data[$i] ^ $masks[$i%4]; } return $text; } //Encode message for transfer to client. function mask($text) { $b1 = 0x80 | (0x1 &amp; 0x0f); $length = strlen($text); if($length &lt;= 125) $header = pack('CC', $b1, $length); elseif($length &gt; 125 &amp;&amp; $length &lt; 65536) $header = pack('CCn', $b1, 126, $length); elseif($length &gt;= 65536) $header = pack('CCNN', $b1, 127, $length); return $header.$text; } //handshake new client. function perform_handshaking($receved_header,$client_conn, $host, $port) { $headers = array(); $lines = preg_split("/ /", $receved_header); foreach($lines as $line) { $line = chop($line); if(preg_match('/\A(\S+): (.*)\z/', $line, $matches)) { $headers[$matches[1]] = $matches[2]; } } $secKey = $headers['Sec-WebSocket-Key']; $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'))); //hand shaking header $upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake " . "Upgrade: websocket " . "Connection: Upgrade " . "WebSocket-Origin: $host " . "WebSocket-Location: wss://$host:$port/demo/shout.php ". "Sec-WebSocket-Accept:$secAccept "; socket_write($client_conn,$upgrade,strlen($upgrade)); } </code></pre> </div>

Gorilla Websocket手动关闭客户端连接_course

<div class="post-text" itemprop="text"> <p>I try to close connect manual(use <a href="https://dwst.github.io/" rel="nofollow noreferrer">Dark WebSocket Terminal</a>),but the client tell me 1005 (No Status Rcvd)<br> Server:</p> <pre><code>ReadLoop: for { mt, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) log.Println("messageType:", mt) if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) { log.Printf("error: %v", err) } c.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, "")) break ReadLoop } log.Printf("recv: %s", message) //do sth in here err = c.WriteMessage(mt, message) if err != nil { //WriteMessage wrong log.Println("write:", err) break ReadLoop } } </code></pre> <p>It is not work and show the expected outputting the following:</p> <pre><code>read: websocket: close 1005 (no status) messageType: -1 error: websocket: close 1005 (no status) </code></pre> <p>How should i go about this?</p> </div>

Javascript websocket不会连接到php websocket_course

<div class="post-text" itemprop="text"> <p>So I've been trying to get this whole connection between <em>PHP</em> socket server and <em>Javascript</em> websockets working, but I cant get them to connect. I have looked everywhere to figure out what I'm doing wrong. My guess is it's the protocol but I have no idea. Everything helps, comment if you have questions.</p> <p><strong>Client-Side Example</strong></p> <pre><code>&lt;script&gt; var connection = new WebSocket('ws://127.0.0.1:4446'); connection.onopen = function () { connection.send('Ping'); // Send the message 'Ping' to the server }; // Log errors connection.onerror = function (error){ console.log('WebSocket Error ' + error); }; // Log messages from the server connection.onmessage = function (e) { console.log('Server: ' + e.data); }; &lt;/script&gt; </code></pre> <p><strong>Server-Side Example -PHP</strong></p> <pre><code>&lt;?php $conn = stream_socket_server('tcp://127.0.0.1:4446'); while ($socket = stream_socket_accept($conn)) { $pkt = stream_socket_recvfrom($socket, 1500, 0, $peer); if (false === empty($pkt)) { stream_socket_sendto($socket, $pkt, 0, $peer); } fclose($socket); usleep(10000); //100ms delay } stream_socket_shutdown($conn, \STREAM_SHUT_RDWR); ?&gt; </code></pre> <p><strong>Console Log Error</strong></p> <pre><code>VM4666:35 WebSocket connection to 'ws://127.0.0.1:4446/' failed: Error during WebSocket handshake: net::ERR_INVALID_HTTP_RESPONSE </code></pre> <p>I understand that there are many questions on here similar but I cant seem to find a solution, I appreciate any help!</p> </div>

手机浏览器websocket，无法连接一直error_course

``` var websocket = null; if ('WebSocket' in window) { websocket = new WebSocket("ws://localhost:8080/springws/websocket/socketServer.do"); } else if ('MozWebSocket' in window) { websocket = new MozWebSocket("ws://localhost:8080/springws/websocket/socketServer.do"); } else { websocket = new SockJS("http://localhost:8080/springws/sockjs/socketServer.do"); } websocket.onopen = onOpen; websocket.onmessage = onMessage; websocket.onerror = onError; websocket.onclose = onClose; ``` 一直是监听到error，请问有了解的吗。 电脑端浏览器是正常的，手机浏览器检测有WebSocket

websocket设置协议和来源_course

<div class="post-text" itemprop="text"> <p>i use this lib: <a href="https://github.com/gorilla/websocket" rel="nofollow noreferrer">https://github.com/gorilla/websocket</a> how to set protocol and origin,</p> <p>code :</p> <pre><code>func InitWSSClient(url1, protocol, origin string) { u := url.URL{Scheme: "ws", Host: url1} fmt.Println(url1,u.String()) d :=websocket.DefaultDialer //c, _, err := websocket.DefaultDialer.Dial(u.String(), nil) c, _, err :=d.Dial(u.String(),nil) var limit int64 =1024 * 1024 *32 if err != nil { log.Fatal("dial:", err) } c.SetReadLimit(limit) go readWSMessage(c) go sendWSmessage(c) } func readWSMessage(ws *websocket.Conn) error { for { _,message,err := ws.ReadMessage() if err != nil { log15.Error("receiveWebsocket ", "error", err) panic("error") } assignmentWebsocket(string(message)) } } func sendWSmessage(ws *websocket.Conn) error { for { select { case params := &lt;-WebsocketParams: fmt.Println("ws send messages", params) err :=ws.WriteMessage(websocket.TextMessage,[]byte(params)) if err != nil { log15.Error("receiveWebsocket ", "error", err) panic("error") } } } } </code></pre> <p>x.net.websocket set these element like this :</p> <pre><code>websocket.Dial(url, protocol, origin) </code></pre> <p>how to achieve this function in gorilla/websocket/, ths you help. i try many solutions is not working. if you know any solutions, </p> <p>found the solution:</p> <pre><code>d := websocket.DefaultDialer d.Subprotocols = []string{protocol} header :=http.Header{} header.Set("origin",origin) </code></pre> </div>

springcloud下websocket无法通过网关连接_course

在springcloud下使用websocket，前端框架使用vue 若前端直接调用websocket的服务(不走网关），则可正常连接（url: http://localhost:8604/webSocketServer)） 若前端通过网关来连接websocket的服务，则会报404和一些跨域的问题。(url: http:localhost:9091/system-otherService/webSocketServer) 注: 8604为webSocket服务的端口，9091为网关的端口 前端：  后台： websocket配置:  网关路由 network：  错误信息：

带有Web代理的Golang Gorilla Websocket_course

<div class="post-text" itemprop="text"> <p>I'm working on a POC using Gorilla/Websocket to communicate, through a Web Proxy, with the Websocket Check Website "echo.websocket.org".</p> <p>I'm using the free online Proxy "hide.me/en/" for testing.</p> <p>When I simply try to communicate with "echo.websocket.org" (Server side), my client-site Websocket POC reach the response.</p> <p>But when i try to add the Proxy gesture, everything goes wrong :(</p> <p>Here is a sample of my code :</p> <pre><code>package main import ( "flag" "log" "net/url" "os" "os/signal" "time" "github.com/gorilla/websocket" "net/http" ) var addrWebsocket = flag.String("addrWebsocket", "echo.websocket.org", "http service address") func main() { flag.Parse() log.SetFlags(0) interrupt := make(chan os.Signal, 1) signal.Notify(interrupt, os.Interrupt) //Initialize the WebSocket URL and the Path to follow uWS := url.URL{Scheme: "wss", Host: *addrWebsocket} //Initialize the Proxy URL and the Path to follow uProxy, _ := url.Parse("https://hide.me/en/proxy") //Set the Dialer (especially the proxy) dialer := websocket.Dialer{ Proxy: http.ProxyURL(uProxy), } //dialer := websocket.DefaultDialer ==&gt; with this default dialer, it works ! c, _, err := dialer.Dial(uWS.String(), nil) // ==&gt; With the proxy config, it fails here ! defer c.Close() done := make(chan struct{}) go func() { defer c.Close() defer close(done) for { _, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) return } log.Printf("recv: %s", message) } }() ticker := time.NewTicker(time.Second) defer ticker.Stop() for { select { case t := &lt;-ticker.C: err := c.WriteMessage(websocket.TextMessage, []byte(t.String())) if err != nil { log.Println("write:", err) return } case &lt;-interrupt: log.Println("interrupt") err := c.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, "")) if err != nil { log.Println("write close:", err) return } select { case &lt;-done: case &lt;-time.After(time.Second): } c.Close() return } } } </code></pre> <p>I'm a very beginner in Go so don't hesitate to correct me if my code un not clear and clean.</p> <p>Thanks for your help !</p> </div>

WebSocket客户端身份验证方法_course

<div class="post-text" itemprop="text"> <p><strong>How to authenticate the client connecting to the websocket server?</strong></p> <p>In http we could use Oauth 2.0 to authenticate the user and the client too. But in websocket I am not able to understand how to do so.</p> <p>As far as I can understand for authentication of the user connecting we could just ask the client to send a message with a token to authenticate the user. But how to prevent an un-identified client to connect to the server?</p> <p><strong>Isn't there any header for token based authentication for websocket</strong> as that would allow for both the authentication simultaneously just as in any Oauth 2.0 Rest api authentication. </p> </div>

如何在GO中存储WebSocket连接_course

<div class="post-text" itemprop="text"> <p>I want to store client websocket connection into <code>wsList</code>, and send response in uniform. but it will return "use of closed network connection". How to fix it? </p> <pre><code>import { "code.google.com/p/go.net/websocket" ... } var wsList []*websocket.Conn func WShandler(ws *websocket.Conn) { wsList = append(wsList, ws) go sendmsg() } func sendmsg() { for _, conn := range wsList { if err := websocket.JSON.Send(conn, outmsg); err != nil { fmt.Printf("%s", err) //"use of closed network connection" } } } </code></pre> </div>

通过消息关闭Websocket连接_course

<div class="post-text" itemprop="text"> <p>How is it possible to close a websocket connection and pass it a message / code?</p> <p>The docs only define <code>func (ws *Conn) Close() error</code> without any arguments</p> <p>I would like to receive the event from JavaScript like this:</p> <pre><code>websocket.onclose = function(event) { console.log(event); }; </code></pre> <p>I am using <a href="https://godoc.org/golang.org/x/net/websocket" rel="nofollow">golang.org/x/net/websocket</a></p> </div>

Golang Websocket客户端关闭了连接_course

<div class="post-text" itemprop="text"> <p>I have a golang connection. If the client opened the connection the database change the online column to 1. Here is my code but I didnt implement the last thing. My question, how can I change the database column to 0 if the client closed the connection. How can I track the client, and catch the connection close? </p> <pre><code>package main import ( "golang.org/x/net/websocket" "fmt" "log" "net/http" "strconv" ) type Clients struct { webs *websocket.Conn clientAddr string id int } var ( ActiveClients = make(map[Clients]int) ) func Echo(ws *websocket.Conn){ var err error client := ws.Request().RemoteAddr sockCli := Clients{webs: ws, clientAddr: client, id: 0} ActiveClients[sockCli] = 1 for{ var reply string if err = websocket.Message.Receive(ws, &amp;reply); err != nil{ fmt.Println("Cant receive", err) break }else{ if sockCli.id == 0{ sockCli.id, err = strconv.Atoi(reply) } } if err = websocket.Message.Send(ws, "id:"+strconv.Itoa(sockCli.id)); err != nil{ fmt.Println("Cant send") } for cs, _ := range ActiveClients { if cs.id == 1{ if err = websocket.Message.Send(cs.webs, "asd"); err != nil { // we could not send the message to a peer log.Println("Could not send message to ", cs.clientAddr, err.Error()) } }else { fmt.Println("No") } } } } func main(){ http.Handle("/", websocket.Handler(Echo)) if err := http.ListenAndServe(":1234", nil); err != nil{ log.Fatal("ListenAndServe: ", err) } } </code></pre> </div>

核心php中的websocket客户端_course

<div class="post-text" itemprop="text"> <p>I am trying to send data to PHP websocket server, although it sends the data but the data received is a garbage values. How can fix this to get correct values posted to websocket php server?</p> <p>Below is my websocket php client script</p> <pre><code>&lt;?php $host = 'example.com:9000/server.php'; //where is the websocket server $port = 9000; //ssl $local = "http://localhost/"; //url where this script run $data = json_encode(array("server_msg"=&gt; "1","device_id"=&gt; "DDD-123455678")); //data to be send $head = "GET / HTTP/1.1"." ". "Host: $host"." ". "Upgrade: websocket"." ". "Connection: Upgrade"." ". "Sec-WebSocket-Key: asdasdaas76da7sd6asd6as7d"." ". "Sec-WebSocket-Version: 13"." ". "Content-Length: ".strlen($data)." "." "; ////WebSocket handshake $sock = fsockopen($host, $port, $errno, $errstr, 2); fwrite($sock, $head ) or die('error:'.$errno.':'.$errstr); $headers = fread($sock, 2000); fwrite($sock, "\x00$data\xff" ) or die('error:'.$errno.':'.$errstr); $wsdata = fread($sock, 2000); //receives the data included in the websocket package "\x00DATA\xff" $retdata = trim($wsdata,"\x00\xff"); //extracts data ////WebSocket handshake fclose($sock); echo $retdata; ?&gt; </code></pre> <p>Thanks</p> <p>Hi, </p> <p>I have already tried it and it gives me error as below:</p> <p>Fatal error: Uncaught exception 'WebSocket\ConnectionException' with message 'Connection to 'ws://************/server.php' in /var/www/webclientphp/vendor/textalk/websocket/lib/Client.php on line 149</p> <p>WebSocket\ConnectionException: Connection to 'ws://************/server.php' failed: Server sent invalid upgrade response: HTTP/1.1 101 Web Socket Protocol Handshake Upgrade: websocket Connection: Upgrade WebSocket-Origin: ************ WebSocket-Location: ws://************:9000/demo/shout.php Sec-WebSocket-Accept:Kfh9QIsMVZcl6xEPYxPHzW8SZ8w= in /var/www/webclientphp/vendor/textalk/websocket/lib/Client.php on line 149</p> <p>Please help</p> </div>

从websocket收到消息时，不会导致“ Websocket：关闭1011”_course

<div class="post-text" itemprop="text"> <p>I'm trying to subscribe to an event from a client to a server. I can subscribe to the event using JavaScript but when I use <code>Golang</code> and the <code>Gorilla Websocket library</code> I get a</p> <blockquote> <p>'websocket: close 1011 (internal server error)'</p> </blockquote> <p>every time I start a read from the socket.</p> <p>I tried using the <code>/x/websocket</code> library as well but when I tried to read from the socket I end up hanging and I dont get the '1011' error.</p> <p>If I use this JavaScript code on my browser it works:</p> <pre><code>&lt;html&gt; &lt;head&gt; &lt;/head&gt; &lt;body&gt; &lt;script&gt; var socket = new WebSocket("ws://blehip:blehpport"); function send(data) { socket.send(JSON.stringify(data)); } socket.onopen = function() { send({ action: 'subscribe', auth_token: 'Bleh', request_id: 'Bleh', data: { account_id: 'bleh', binding: "bleh" } }); } socket.onmessage = function(raw_message) { var json_data = JSON.parse(raw_message.data); console.log(json_data); }; &lt;/script&gt; &lt;/body&gt; &lt;/html&gt; </code></pre> <p>I get a stream of JSON objects in real time.</p> <p>This is my small Golang, Gorilla/Websockets script</p> <pre><code>func main() { var server = flag.String("server", "blehIP:BlehPort", "server address") var wg sync.WaitGroup flag.Parse() url := url.URL { Scheme: "ws", Host: *server, Path: "", } conn, _, err := websocket.DefaultDialer.Dial(url.String(), nil) if err != nil { log.Fatal("Dial Error: ", err) } defer conn.Close() payload := []byte(`{"action":"subscribe",`+ `"auth_token":"` + bleh + `",`+ `"request_id":"` + bleh + `",`+ `"data": {`+ `"account_id":"` + bleh + `",`+ `"binding":"` + bleh + `"}`+ `}`) wg.Add(1) go func() { defer conn.Close() defer wg.Done() err = conn.WriteMessage(websocket.TextMessage, payload) if err != nil { log.Println("Write Error: ", err) return } m := frame{} err := conn.ReadJSON(&amp;m) if err != nil { log.Println("WebScoket closed.", err) return } // msg := string(bytes[:]) fmt.Printf("%v", m) }() wg.Wait() return } </code></pre> <blockquote> <p>The error returned is: WebSocket closed. websocket: close 1011 (internal server error)</p> </blockquote> </div>

websocket 如何兼容低版本浏览器？_course

[WebSocket] debug enabled [WebSocket] policy file: xmlsocket://211.95.3.194:843 [WebSocket] cannot connect to Web Socket server at ws://211.95.3.194:11113/demo01/MyHtml.html?message_to=&message_me= (SecurityError: Error #2048) make sure the server is running and Flash socket policy file is correctly placed [WebSocket] closed 我从网上下载了很多demo 大致都是flash+websocket.js+WebSocketMain.swf但为什么总是出这个错？

如何升级客户端php websocket的协议。 我正在使用phpWebSocket_course

<div class="post-text" itemprop="text"> <p><code>&lt;?php $host = 'localhost'; //where is the websocket server $port = 8080; //ssl $local = "http://localhost/php-websockets-master/"; //url where this script run $data = '{"id": 2,"command": "server_info"}'; //data to be send $head = "GET / HTTP/1.1"." ". "Upgrade: WebSocket"." ". "Connection: Upgrade"." ". "Origin: $local"." ". "Host: $host"." ". "Content-Length: ".strlen($data)." "." "; ////WebSocket handshake $sock = fsockopen($host, $port, $errno, $errstr, 2); fwrite($sock, $head ) or die('error:'.$errno.':'.$errstr); $headers = fread($sock, 2000); sleep(1); fwrite($sock, "\x00$data\xff" ) or die('error:'.$errno.':'.$errstr); $wsdata = fread($sock, 2000); //receives the data included in the websocket package "\x00DATA\xff" $retdata = trim($wsdata,"\x00\xff"); //extracts data ////WebSocket handshake fclose($sock); echo $headers; echo $retdata; ?&gt;</code></p> <p>is the code I am using and the server side just echoes the string sent to it. I have tested server side code written in php and it works fine with javascript client side code. When the above mentioned code is ran, it prints only header and that is "HTTP/1.1 426 Upgrade Required Sec-WebSocketVersion: 13". Any help explaining it would be great. Please don't suggest using Ratchet or React php. If You can suggest some library that does not need to be installed then that too would be of great help.</p> </div>

使用nodejs客户端访问golang websocket服务器_course

<div class="post-text" itemprop="text"> <p>I am a newbie to NodeJS. Assume that I have a echo server implemented with Golang's websocket package:</p> <pre> package main import ( "code.google.com/p/go.net/websocket" "log" "net/http" ) func EchoServer(ws *websocket.Conn) { var msg string websocket.Message.Receive(ws, &amp;msg) log.Printf("Message Got: %s ", msg) websocket.Message.Send(ws, msg) } func main() { http.Handle("/echo", websocket.Handler(EchoServer)) err := http.ListenAndServe(":8082", nil) if err != nil { panic(err.Error()) } } </pre> <p>What should the nodejs client code look like ? </p> </div>