websocket如何定时推送随机数到客户端?

用WebSocket,WebWorker和requestAnimationFrame如何实现服务端定时推送随机数到客户端?

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Python+OpenCV计算机视觉

Python+OpenCV计算机视觉

webworker websocket服务端推送消息到客户端?

websocket服务器端已实现主动推送数据到客户端,如何能用到webworker

Swoole将websocket数据从服务器发送到客户端

<div class="post-text" itemprop="text"> <p><strong>Hi all!</strong></p> <p>I use swoole for WebSockets.</p> <p><strong>I create clietn part:</strong></p> <pre><code>&lt;script&gt; var ws = new WebSocket('ws://site.ll:9502/?user=tester01'); ws.onmessage = function(evt) { console.log(evt.data); }; ws.onopen = function (event) { ws.send('test'); } &lt;/script&gt; </code></pre> <p><strong>Create WebServer part:</strong></p> <pre><code>$server = new swoole_websocket_server("127.0.0.1", 9502); $server-&gt;on("start", function ($server) { echo "Swoole http server is started at http://127.0.0.1:9502 "; }); $server-&gt;on('open', function($server, $req) { echo "connection open: {$req-&gt;fd} "; }); $server-&gt;on('message', function($server, $frame) { echo "received message: {$frame-&gt;data} "; $server-&gt;push($frame-&gt;fd, json_encode(["hello", "world"])); }); $server-&gt;on('close', function($server, $fd) { echo "connection close: {$fd} "; }); $server-&gt;start(); </code></pre> <p><strong>Create send from server part:</strong></p> <pre><code>$client = new swoole_client(SWOOLE_SOCK_TCP); if (!$client-&gt;connect('127.0.0.1', 9502, -1)) { exit("connect failed. Error: {$client-&gt;errCode} "); } $client-&gt;send("hello world "); echo $client-&gt;recv(); $client-&gt;close(); </code></pre> <p>I trying to create TCP server inside WebSocket server, just adding next part inside "on start" callback:</p> <pre><code>$server2 = new swoole_server("127.0.0.1", 9503); $server2-&gt;on('connect', function ($server2, $fd){ echo "connection open: {$fd} "; }); $server2-&gt;on('receive', function ($server2, $fd, $from_id, $data) { $server2-&gt;send($fd, "Swoole: {$data}"); $server2-&gt;close($fd); }); $server2-&gt;on('close', function ($server2, $fd) { echo "connection close: {$fd} "; }); $server2-&gt;start(); </code></pre> <p>But Just receive an error: </p> <blockquote> <p>Swoole\Server::__construct(): eventLoop has already been created. unable to create swoole_server.</p> </blockquote> <p>I need to send data from server to client. How can I do this? In workerman library I doing next: <a href="https://github.com/Shkarbatov/WebSocketPHPWorkerman/blob/master/worker.php" rel="nofollow noreferrer">https://github.com/Shkarbatov/WebSocketPHPWorkerman/blob/master/worker.php</a></p> </div>

websocket 服务器推送数据库数据到浏览器

刚接触web方面的知识,想实现一个小项目,就是服务器不断的从数据库里取出最新的数据,然后把数据推送给web浏览器,看资料说websocket可以很好的实现这个功能,但是websocket的API就那几个监听事件,况且Onmessage,在接受到浏览器到服务器,或者服务器到浏览器的数据时,才会执行,但是,我现在不用浏览器发请求,就是浏览器连上服务器后,服务器就一直不断的推送数据到浏览器,用java实现,应该怎么做呢?有谁做过这方面的东西,请说说你们的做法

websocket 用c++编写客户端的问题

用MFC CAsyncSocket这个类的socket与服务器connect之后, 我发送了头:Sec-WebSocket-Key,Sec-WebSocket-Version: 13 等内容 等取得了服务器返回的应答:Sec-WebSocket-Accept,Upgrade:Websocket等内容 应该是握手成功了。 之后我在用CAsyncSocket的send发送文本过去服务器就没有返回数据了,服务器也木有向我返回数据。是不是发送的数据要经过编码或者是什么? 请问有websocket 用c++编写客户端 示例代码吗?

websocket 如果服务端主动断开连接客户端应该如何收到反馈

如果存在服务器主动断开与客户端连接的websocket的情况, 服务器端或者客户端应该如何写才能让客户端接收到连接被断开连接的反馈? 麻烦定时检测是否断开的这种方法就不要说了。

Websocket正在运行,但客户端无法连接

<div class="post-text" itemprop="text"> <p>I've been working on this simple websocket tutorial from the guys over at tuts+ <a href="http://net.tutsplus.com/tutorials/javascript-ajax/start-using-html5-websockets-today/" rel="nofollow">http://net.tutsplus.com/tutorials/javascript-ajax/start-using-html5-websockets-today/</a></p> <p>I copied the code over and only changed 3 lines of code (changed the port number). </p> <pre><code>var host = "ws://localhost:8000/socket/server/startDaemon.php"; //from client.php $WebSocket = new socketWebSocket('localhost',8000); //from startDaemon.php public function __construct($host='localhost',$port=8000,$max=100) //from socket.class.php </code></pre> <p>I have all these files in one folder on a linode server and all I get is "Socket Status: 3 (Closed)". You can see the client.php here <a href="http://ckfrantz.com/arena/client.php" rel="nofollow">http://ckfrantz.com/arena/client.php</a></p> <p>I appreciate your time.</p> </div>

websocket消息推送,如何实现不频繁查询数据库,还能将数据库中数据量实时更新到前端界面上?

问题描述: 目前有一个业务场景,是通过websocket来实现消息推送的,目前的做法是,每次接收到一条新的消息后,更新到数据库后,再通过查询数据库将数据库中符合该用户组的消息数量统计出来,并通过websocket推送到前端界面上,进行显示。现在的问题是,若在某一个时刻产生大量的新消息,每插入一条消息,均要对数据库进行查询消息总量,这样会对数据库产生很大的压力,鉴于这种情况下,该如何保证在不频繁查询数据库的情况下,还能保证前端界面上显示的消息总数和数据库保持一致呢?

websocket发送信息到多个客户端是发完一个再发另一个的吗?

如果我的服务端不需要接受客户端的信息,当客户端请求后就不停的给客户端发消息,即使所有客户端都断开连接了,还在发,这种模式行吗,正常的websocket服务端是不是要判断客户端发来的信息来了解客户端的状态

如何使用Go和gorilla websocket仅发送给一个客户端,而不是所有客户端

<div class="post-text" itemprop="text"> <p>I am trying to learn websockets with Go. I have been looking at examples with gorilla websocket.</p> <p>I have checked out these 2 examples that show how to use gorilla websocket:</p> <p><a href="https://github.com/gorilla/websocket/tree/master/examples" rel="nofollow">https://github.com/gorilla/websocket/tree/master/examples</a></p> <p><a href="https://www.youtube.com/watch?v=ysAZ_oqPOo0" rel="nofollow">https://www.youtube.com/watch?v=ysAZ_oqPOo0</a></p> <p>All of these examples show how to connect to a websocket server, send and receive texts. But what I don't understand is how you can send to only one client. Because in a real world application you will have users, and we don't want all users to receive the same message and same data. Is there a way for me to get the unique id of a connection which I can save in a database like redis and link it to a user id in the same database, and then use that websocket id to send back to a specific client if that user id received a message or a notification? Is this how one would go about and achieve something like this? If that is the case, how would I that?</p> </div>

websoket长连接定时推送消息至前端

ssh(spring,status,hibernate)框架如何使用websoket长连接定时向前端推送消息做到前端实时刷新局部数据,有没有哪位好心的大神会的,有实例更好(有java和前端代码和注释)

请问,WebSocket推送消息时如何拼接历史消息?

- 服务器端每秒发送一条消息,持续1分钟,第一次打开并使用WebSocket连接上服务器后接收消息,到第5秒时关闭浏览器 - 第5-第10秒间的消息类似于web微信里的离线消息 - 到第10秒时再次打开该页面,要求消息中包含第0至第10秒的历史消息,后续的消息也能append

websocket 推送消息通知

就比如我要发帖 点发帖会提示我有一个未结的帖子消息通知,使用websocket怎么做的哦? websocket服务端怎么查询数据库?项目用的struts

react项目,websocket推送过来的消息并发较大,导致model更新不同步的问题

我是用dva搭建的项目,项目中在model模块开启了websocket监听,接收到对应的消息类型,下发到对应的异步函数中 ![图片说明](https://img-ask.csdn.net/upload/201903/15/1552614682_13306.png) 在acceptMessage中更新我的state ![图片说明](https://img-ask.csdn.net/upload/201903/15/1552614746_639769.png) 但是websocket推送过来的消息并发较大,这样就导致在accpetMessage中获取的messageList的长度都是相同,最后更新的时候messageList就会丢掉很多消息, 在下初学react,希望大神指点迷津!

springMVC + websocket实现实时向页面推送消息

场景是这样:服务器获取到数据,通过springMVC框架,运用websocket,实时向页面推送1000条信息。 不需要做信息交互,信息是服务器接收到的,直接推送到前端页面就好。 有什么教程吗?或者代码?

WebSocket客户端与Java的Socket服务器通信

客户端使用websocket,服务器使用Java Socket。客户端经过new webSocket(utl)之后,服务器端可以收到请求头,但是客户端的webSocket.readyState一直是0,没有连接成功,这个是因为什么呢?是不是因为服务器端不可以用Java Socket

WebSocket 服务端与客户端互发消息问题?

WebSocket 如果服务端不停的发消息给客户端,客户端处理消息又不停的给服务端发处理结果消息,这样会有什么问题?本人遇到的情况是如果服务端一直在发,就收不到客户端发的消息,是不是因为只有一个连接通道,服务端和客户端不能同时发?

Websocket发送到特定客户端而不是广播

<div class="post-text" itemprop="text"> <p>I'm trying to modify the gorilla chat example to to send a message to a specific client instead of broadcast. First I'm storing the specific client in the hub against it's Id.</p> <p><strong>Hub.go</strong></p> <pre><code>type Hub struct { Clients map[int]*Client // Changed this piece to store id (int) Broadcast chan []byte Register chan *Client Unregister chan *Client } func (h *Hub) Run() { for { select { case client := &lt;-h.Register: fmt.Println("hub client register") h.Clients[client.Id] = client case client := &lt;-h.Unregister: fmt.Println("hub client Unregister") fmt.Println(h.Clients[client.Id]) if h.Clients[client.Id] != nil { delete(h.Clients, client.Id) close(client.Send) } case message := &lt;-h.Broadcast: fmt.Println("to send to a specific client", string(message)) } } } </code></pre> <p><strong>Client</strong></p> <p>I've added a field Id int to Client to know which client has sent a message</p> <pre><code>type Client struct { Hub *Hub Conn *websocket.Conn Send chan []byte Id int // Id of the client, } func (c *Client) readPump() { defer func() { c.Hub.Unregister &lt;- c c.Conn.Close() }() c.Conn.SetReadLimit(maxMessageSize) c.Conn.SetReadDeadline(time.Now().Add(pongWait)) c.Conn.SetPongHandler(func(string) error { c.Conn.SetReadDeadline(time.Now().Add(pongWait)); return nil }) for { _, message, err := c.Conn.ReadMessage() if err != nil { if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) { log.Printf("error: %v", err) } break } message = bytes.TrimSpace(bytes.Replace(message, newline, space, -1)) fmt.Println("client read message", string(message), "from", c.Id) // {"to":512,"message":"Hi there."} c.Hub.Broadcast &lt;- message } } </code></pre> <p>What are the next steps to take to be able to send the message to a specific client instead of broadcasting.</p> <p>the message itself is coming as JSON from the client specifying 'to' indicating who to send and what message to send.</p> <pre><code>{"to":512,"message":"Hi there."} </code></pre> </div>

spring boot websocket wss 客户端

1.目前需要做依据spring-websocket基础上的WSS的客户端,目前只实现了ws,不知道如何实现WSS 2. 创建连接的代码 //连接 public static boolean connection(String name, String host, int port) { String url = "wss://" + host + ":" + port + "/websocket/" + name; WebSocketConnectionManager manager = new WebSocketConnectionManager(client(), handler(), url); manager.setAutoStartup(true); HttpHeaders httpHeaders = new HttpHeaders(); manager.setHeaders(httpHeaders); manager.start(); } //client @Bean public static StandardWebSocketClient client() { return new StandardWebSocketClient(); } 目前是不知道如何生成一个带TLS的StandardWebSocketClient,希望有人帮忙看看

websocket只连接了一个客户客户端互发消息,但是每发一次消息,服务端就提示连接人数加一个,这是为什么

websocket只连接了一个客户客户端互发消息,但是每发一次消息,服务端就提示连接人数加一个,这是为什么 ``` // concurrent包的线程安全Set,用来存放每个客户端对应的MyWebSocket对象。 服务端 private static CopyOnWriteArraySet<StatusWS> webSocketSet = new CopyOnWriteArraySet<StatusWS>(); private static Map<String, JSONObject> webSocketMap = new HashMap<String, JSONObject>(); // 与某个客户端的连接会话,需要通过它来给客户端发送数据 private Session session; private String APPID; /** * 连接建立成功调用的方法 */ @OnOpen public void onOpen(Session session) { this.session = session; webSocketSet.add(this); // 加入set中 addOnlineCount(); // 在线数加1 logger.info("有新连接加入!当前在线人数为" + getOnlineCount()); } 客户端: $("#btnConnection").click(function() { socket = new WebSocket("ws://203.195.240/status"); //打开事件 socket.onopen = function() { alert("Socket 已打开"); //socket.send("这是来自客户端的消息" + location.href + new Date()); }; //获得消息事件 socket.onmessage = function(msg) { console.log(msg.data); }; //关闭事件 socket.onclose = function() { alert("Socket已关闭"); }; //发生了错误事件 socket.onerror = function() { alert("发生了错误"); } }); //发送消息 $("#btnSend").click(function() { socket.send("1001,1"); }); //关闭 $("#btnClose").click(function() { socket.close(); }); ```

2019 Python开发者日-培训

2019 Python开发者日-培训

150讲轻松搞定Python网络爬虫

150讲轻松搞定Python网络爬虫

设计模式(JAVA语言实现)--20种设计模式附带源码

设计模式(JAVA语言实现)--20种设计模式附带源码

YOLOv3目标检测实战:训练自己的数据集

YOLOv3目标检测实战:训练自己的数据集

java后台+微信小程序 实现完整的点餐系统

java后台+微信小程序 实现完整的点餐系统

三个项目玩转深度学习(附1G源码)

三个项目玩转深度学习(附1G源码)

初级玩转Linux+Ubuntu(嵌入式开发基础课程)

初级玩转Linux+Ubuntu(嵌入式开发基础课程)

2019 AI开发者大会

2019 AI开发者大会

玩转Linux:常用命令实例指南

玩转Linux:常用命令实例指南

一学即懂的计算机视觉(第一季)

一学即懂的计算机视觉(第一季)

4小时玩转微信小程序——基础入门与微信支付实战

4小时玩转微信小程序——基础入门与微信支付实战

Git 实用技巧

Git 实用技巧

Python数据清洗实战入门

Python数据清洗实战入门

使用TensorFlow+keras快速构建图像分类模型

使用TensorFlow+keras快速构建图像分类模型

实用主义学Python(小白也容易上手的Python实用案例)

实用主义学Python(小白也容易上手的Python实用案例)

程序员的算法通关课:知己知彼(第一季)

程序员的算法通关课:知己知彼(第一季)

MySQL数据库从入门到实战应用

MySQL数据库从入门到实战应用

机器学习初学者必会的案例精讲

机器学习初学者必会的案例精讲

手把手实现Java图书管理系统(附源码)

手把手实现Java图书管理系统(附源码)

极简JAVA学习营第四期(报名以后加助教微信:eduxy-1)

极简JAVA学习营第四期(报名以后加助教微信:eduxy-1)

.net core快速开发框架

.net core快速开发框架

玩转Python-Python3基础入门

玩转Python-Python3基础入门

Python数据挖掘简易入门

Python数据挖掘简易入门

微信公众平台开发入门

微信公众平台开发入门

程序员的兼职技能课

程序员的兼职技能课

Windows版YOLOv4目标检测实战:训练自己的数据集

Windows版YOLOv4目标检测实战:训练自己的数据集

HoloLens2开发入门教程

HoloLens2开发入门教程

微信小程序开发实战

微信小程序开发实战

Java8零基础入门视频教程

Java8零基础入门视频教程

相关热词 c# 开发接口 c# 中方法上面的限制 c# java 时间戳 c#单元测试入门 c# 数组转化成文本 c#实体类主外键关系设置 c# 子函数 局部 c#窗口位置设置 c# list 查询 c# 事件 执行顺序
立即提问
相关内容推荐