websocket 频繁推送数据

相关推荐

• websocket 频繁推送数据 javascriptvue.js

  4月前
  回答 6 已采纳 前端使用的是vue框架 部分功能需要WebSocket实现，但是服务端频繁发来数据 浏览器过五分钟就会卡死无响应，在客户端这里或者服务端有什么好的解决办法吗？
• 怎么调用websocket作为通道发送数据 java

  5年前
  回答 2 已采纳 1.现有多个线程查询不同的设备获取不同的数据。 2.当网页打开后自动产生一个websocket连接。 上面12两点已经完成，但是现在对我来说查询线程和websocket它们相互独立，怎么才能在查询线程中调用websocket的send方法把数据传到前台网页呢。
• Golang WebSocket数据不正确

  3年前
  回答 1 已采纳 I'm using x.net.websocket to read data from a websocket. The data is relatively large. When I read it, I can't read it completely, so it is cut off. Is there any way to solve it? func receiveWebsocket(ws *websocket.Conn) error { for { var msg = make([]byte, 1024*1024) // 1024kb m, err := ws.Read(msg) if err != nil { log15.Error("ws read error", "error", err) return err } fmt.Println("length ---",m, string(msg)) response := string(msg[:m]) assignmentWebsocket(response) } } According to the log, the m value is always 4092, even if msg is very large.
• 将Websocket消息发送到Go中的特定频道（使用Gorilla）

  2年前
  回答 1 已采纳 I am very new to Go and have found myself working with sockets as my first project. This is a redundant question, but I have failed to understand how to send a websocket update to a specific channel in Go (using Gorilla). I am using code sample from this link this method. But failed to modify to send messages to specific channel. Here is my sample code main.go func main() { flag.Parse() hub := newHub() go hub.run() http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) { fmt.Println(hub) serveWs(hub, w, r) }) err := http.ListenAndServe(*addr, nil) if err != nil { log.Fatal("ListenAndServe: ", err) } } There is other two files called hub.go and client.go I think hub.go below here something could be done return &Hub{ broadcast: make(chan []byte), register: make(chan *Client), unregister: make(chan *Client), clients: make(map[*Client]bool), } Please suggest what should I change from here? Thanks in advanced. ****UPDATE** What I am trying to do is I have a socket server written in go. Now suppose we have many clients written in react listening on server with a specific url like wss://abc.com/wss1 or may be wss://abc.com/wss2 Now if client wss1 send a message to server, server will emit this message all clients listening on url wss1 not wss2 and vice versa. Till now i have been able to do broadcast to all clients irrespective of wss1 or wss2. Hope I made it clear.
• 如何从golang的websocket服务器向客户端主动发送消息

  3年前
  回答 3 已采纳 I'm a newcomer for the golang and websocket. I'm trying to write a websocket server which can send the messages actively to client once the handshake is done. but my server will just only send the message to the client when got the request from the client. Does anyone know how to implement this feature or where can I find the related answer for that? Thank you so much. the source code is as follows: package main import ( "log" "net/http" ) func handler(w http.ResponseWriter, req *http.Request) { w.Header().Set("Content-Type", "text/plain") w.Write([]byte("Hi, the handshake is completed. ")) w.Write([]byte("Let's start to talk something. ")) } func main() { http.HandleFunc("/", handler) log.Printf("Start to listen on 443.") err := http.ListenAndServeTLS(":443", "server.crt", "server.key", nil) log.Fatal(err) }
• 将Websocket消息发送到Go中的特定客户端（使用Gorilla）

  2年前
  回答 1 已采纳 I am very new to Go and have found myself working with sockets as my first project. This is a redundant question, but I have failed to understand how to send a websocket update to a specific client in Go (using Gorilla). The broad problem that I am trying to solve is - Building a typeahead using websockets and a search engine like ES/Lucene. I have maintained a bunch of indexes on my search engine and have a Go wrapper around it. When I started working on using websockets in Go, I have been finding almost all the examples showing broadcasting mechanism. When I tried to dig into this and tried to modify the example given in Gorilla's github repo based on the examples given in this thread and in this answer, I don't seem to understand connections and how does that fit in client.go Ideally, the way I would like to see this working is - A socket connection between the client and server is established Upon the client sending inputs via the socket, the server fetches it and throws into into a channel (Go channel) The indexing wrapper checks for this channel, and once there is something to fetch, the index is retrieved and written back to the socket How can the server uniquely identify the Client? I have used the examples given on Gorilla's Github repo From my codebase hub.go has the following type Hub struct { // Registered clients. clients map[*Client]bool // Inbound messages from the clients. broadcast chan []byte // Register requests from the clients. register chan *Client // Unregister requests from clients. unregister chan *Client connections map[string]*connection } func newHub() *Hub { return &Hub{ broadcast: make(chan []byte), register: make(chan *Client), unregister: make(chan *Client), clients: make(map[*Client]bool), connection: make(map[*Client]bool), // is this alright? } } func (h *Hub) run() { for { select { case client := <-h.register: h.clients[client] = true case client := <-h.unregister: if _, ok := h.clients[client]; ok { delete(h.clients, client) close(client.send) } case message := <-h.broadcast: for client := range h.connections { select { case client.send <- message: default: close(client.send) delete(h.connections, client) } } } } } and I am unsure with what I should be adding to client.go type Client struct { // unique ID for each client // id string // Hub object hub *Hub // The websocket connection. conn *websocket.Conn // Buffered channel of outbound messages. send chan []byte // connection --> (what should the connection property be?) connection string } Please note - I will be adding an Id field within the Client struct. How can I proceed from here?
• Websocket - 客户端不接收数据 javascriptphp

  9年前
  回答 1 已采纳 I'm writing some app based on websockets (RFC 6455). Unfortunetly it looks like the client (testing on Chrome 18) doesn't receive data, but the server says it is sending... Chrome doesn't say anything Here are main server methods: private function decode($payload) { $length = ord($payload[1]) & 127; if ($length == 126) { $masks = substr($payload, 4, 4); $data = substr($payload, 8); } elseif ($length == 127) { $masks = substr($payload, 10, 4); $data = substr($payload, 14); } else { $masks = substr($payload, 2, 4); $data = substr($payload, 6); } $text = ''; for ($i = 0; $i < strlen($data); ++$i) { $text .= $data[$i] ^ $masks[$i % 4]; } $text = base64_decode($text); return $text; } private function encode($text) { $text = base64_encode($text); // 0x1 text frame (FIN + opcode) $b1 = 0x80 | (0x1 & 0x0f); $length = strlen($text); if ($length <= 125) $header = pack('CC', $b1, $length); elseif ($length > 125 && $length < 65536) $header = pack('CCS', $b1, 126, $length); else $header = pack('CCN', $b1, 127, $length); return $header . $text; } protected function process($user, $msg) { echo '<< '.$msg.N; if (empty($msg)) { $this->send($user->socket, $msg); return; } } protected function send($client, $msg) { $msg = $this->encode($msg); echo '>> '.$msg.N; socket_write($client, $msg, strlen($msg)); }
• 在Websocket中添加自定义数据 phpmysqljquery

  8年前
  回答 1 已采纳 I would like to send the logged in client side username to a websocket script along with the message the client has entered. I need support on implementing another variable- rge username, to be sent with the message. Right now I'm using:https://github.com/Flynsarmy/PHPWebSocket-Chat and the js is Server.send( 'message', text ); with Server being the FancyWebSocket.This is sent to: var FancyWebSocket = function(url) { var callbacks = {}; var ws_url = url; var conn; this.bind = function(event_name, callback){ callbacks[event_name] = callbacks[event_name] || []; callbacks[event_name].push(callback); return this;// chainable }; this.send = function(event_name, event_data){ this.conn.send( event_data ); return this; }; this.connect = function() { if ( typeof(MozWebSocket) == 'function' ) this.conn = new MozWebSocket(url); else this.conn = new WebSocket(url); // dispatch to the right handlers this.conn.onmessage = function(evt){ dispatch('message', evt.data); }; this.conn.onclose = function(){dispatch('close',null)} this.conn.onopen = function(){dispatch('open',null)} }; this.disconnect = function() { this.conn.close(); }; var dispatch = function(event_name, message){ var chain = callbacks[event_name]; if(typeof chain == 'undefined') return; // no callbacks for this event for(var i = 0; i < chain.length; i++){ chain[i]( message ) } } }; Which is binded to my server.php as: $Server->bind('message', 'wsOnMessage'); function wsOnMessage($clientID, $message, $messageLength, $binary)
• 返回元素类后表单提交 javascriptphpjquery

  3年前
  回答 1 已采纳 I'm trying to create customizable checkboxes using buttons. I'm able to differentiate which button class has been selected, but I've been unable to track the button class post form submission. Ideally, instead of reseting the buttons to a default value when the page is loaded or submitted, I can keep whatever input was initially provided. I've tried using the isset() php function, but I don't think it's a valid solution in this circumstance. Are there any alternatives? Find my code below: <form id="my-form" method="post"> <html> <body > <style> .button { color: white; padding: 10px; text-align: center; text-decoration: none; display: inline-block; font-size: 12px; margin: 4px 2px; cursor: pointer; } .button1 { border-radius: 100%; background-color: green; border: none; } .button2 { border-radius: 100%; background-color: red; border: none; } </style> <div id="test1"></div> <div id="test2"></div> <!-- invalid code? <?php echo isset($_POST["t1test"]); echo isset($_POST["t2test"]); echo $_POST["t1test"]; echo $_POST["t2test"]; ?> --> <script type="text/javascript"> function makeButton(div, val) { var element = document.getElementById(val); var button = document.createElement("button"); var span = document.createElement("span"); // change to account for submitted settings if (element == null) { button.setAttribute("class", "button button1"); } else { var cL1 = element.classList.contains("button1"); var cL2 = element.classList.contains("button2"); element.parentNode.removeChild(element); if (cL2 == true) { button.setAttribute("class", "button button1"); } if (cL1 == true) { button.setAttribute("class", "button button2"); } } button.setAttribute("type", "button"); button.setAttribute("id", val); button.setAttribute("name", val); var testDiv = document.getElementById(div); testDiv.appendChild(button); button.addEventListener ("click", function() { makeButton(div, val); }) } window.onload = function() { makeButton("test1", "t1test"); makeButton("test2", "t2test"); } </script> </body> </html> <button id="submit">Submit</button> </form>
• 一个表单中的多个“链接”提交按钮 javascriptphpjquery

  5年前
  回答 3 已采纳 I would like to create a form with multiple submit link buttons. I know it can be done by using and specifying the name of <button> or <input type="button"> something like this: In HTML: <form action="" method="get"> Other form elements here... <button type="submit" name="activated">Activated</button> <button type="submit" name="pending">Pending</button> <button type="submit" name="suspended">Suspended</button> </form> In PHP: <?php if(isset($_GET["activated"])) { Activated codes here... } elseif(isset($_GET["pending"])) { Pending codes here... } elseif(isset($_GET["suspended"])) { Suspended codes here... } ?> I want the submit buttons to be done by using link, not <button> or <input type="submit"> something like this: <a href="#">Activated</a> <a href="#">Pending</a> <a href="#">Suspended</a> I heard that it can be done by using JavaScript or JQuery but I don't know how, anyone knows? Update: What I want to happen is when I clicked the "Activated" link for example, I want only to process the logic under isset($_GET["activated"]). The reason behind: The reason why I want to have a submit link buttons instead of normal submit button tags is that, I want to use this bootstrap dropdown button style to change the status of user(s) on table: and it is based on links, so that's why. PS: Sorry for bad English, not my native language.
• 高并发下，websocket的安全推送，避免websocket推送太频繁挂掉问题

  2年前
  学前班班长的博客 最近项目中遇见一个问题...由于消费十分频繁，websocket经常出现与前端断开连接导致推送失败挂掉。 package com.ncse.zhhygis.collect; import java.io.IOException; import java.util.concurrent.CopyOnWriteArr...
• 项目实例 -- Websocket消息推送

  3年前
  w1992wishes的博客 本篇结构： 背景 ... 消息推送方案 ...Websocket简介 ...Websocket实例 ...HTTP协议的无状态和被动性，使得B/S架构的...基于Flash的消息推送又有Flash支持不好，无法自动穿越防火墙等问题…… Websocket就是在这种情况...
• WebSocket与消息推送

  3年前
  强哥叨逼叨的博客 目录一、Socket简介二、WebSocket简介与消息推送三、WebSocket客户端四、WebSocket服务器端五、测试运行六、小结与消息推送框架6.1、开源Java消息推送框架 Pushlet6.2、开源DotNet消息推送框架SignalR七、代码下载...
• websocket数据过多分批渲染到页面

  3月前
  赵九一和喵小胖的博客 实时数据与设置的上限数据与下限数据同时体现在echarts折线图之中，当实时数据超过上线时触发报警并关机。 由于数据量太大，一秒钟至少一百条，因此实时渲染到echarts上会导致整个页面卡死。 原因分析： 上面已经...
• websocket receive阻塞怎么办_WebSocket 主动推送

  5月前
  weixin_39765057的博客 背景最近，公司在开发一款主动服务机器人，将产生的消息数据通过服务端推送到客户端(H5、iOS、Android)；同时支持用户进行提问，通过 NLP 识别用户意图，然后找到答案并回答用户。本次仅记录在进行部署主动服务通信...
• SpringBoot搭建WebSocket推送服务

  1年前
  Minor_java的博客 WebSocket 使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在 WebSocket API 中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。...
• WebSocket通信，多客户端数据同时发送

  8月前
  weixin_42228937的博客 input type="button" value="发送数据" onclick="send('黎明')"/> <input type="button" value="关闭连接" onclick="onClose()"/> <div id="ht" style="font-size: 15px;"></div> </div&gt...
• websocket实现服务端消息推送

  2年前
  LTELTY的博客 WebSocket全双工通信与消息推送 B/S结构的软件项目中有时客户端需要实时的获得服务器消息，但默认HTTP协议只支持请求响应模式，这样做可以简化web服务器，减少服务器的负担，加快响应速度，因为服务器不需要与客户端...
• 构建通用WebSocket推送网关的设计与实践

  2月前
  高可用架构的博客 HTTP协议是一种无状态的、基于TCP的请求/响应模式的协议，请求只能由客户端发起、服务端进行响应。在大多数场景，这种请求/响应的Pull模式已经可以满足需求。但在某些情形，例如消息推送、...
• JavaScript服务器推送技术之 WebSocket

  3年前
  weixin_33905756的博客 最近在工作中遇到了需要服务器推送消息的场景，这里总结一下收集整理WebSocket相关资料的收获。 1. 概述 1.1 服务器推送 WebSocket作为一种通信协议，属于服务器推送技术的一种，IE10+支持。 服务器推送技术不止一种...