将收到的KuCoin Websocket消息保存到变量，然后保存到数据库
可以通过以下步骤完成：
- 首先，了解KuCoin Websocket，它是KuCoin交易所提供的一种实时通信协议，可用于订阅市场行情、交易深度和订单更新等信息。
- 在前端开发中，可以使用WebSocket API与KuCoin服务器建立WebSocket连接，并监听来自KuCoin服务器的消息。你可以使用JavaScript或其他前端语言来实现这个功能。在接收到消息后，可以将其保存到一个变量中，以便后续处理。
- 后端开发方面，你可以选择使用适合你的编程语言和框架来实现服务器端的WebSocket连接。一些常见的选择包括Node.js的ws模块、Python的websocket库等。在收到来自前端的消息后，你可以将其保存到数据库中。这可以通过使用数据库的API（如MySQL的Python Connector）来实现。在保存到数据库之前，你可能需要对数据进行一些格式化或处理。
- 在数据库中保存数据时，你可以根据你的需求选择不同的方式。例如，你可以创建一个表来存储每个接收到的消息，其中包含消息的各个字段，如时间戳、交易对、价格、数量等。你还可以使用索引来提高查询效率。
- 为了更好地管理和维护数据库，可以考虑使用一些工具和技术。例如，你可以使用数据库管理系统（如MySQL Workbench）来管理数据库架构和执行查询。你还可以使用ORM（对象关系映射）工具，如Sequelize或Django ORM，来简化数据库操作和查询。
- 关于推荐的腾讯云相关产品和产品介绍链接地址，我无法直接提供，但你可以参考腾讯云的云数据库、云服务器、消息队列等产品，这些产品可以帮助你在腾讯云上搭建和管理数据库、服务器和消息传递等功能。
综上所述，通过以上步骤，你可以将收到的KuCoin Websocket消息保存到变量，并将其保存到数据库中。这样，你就能够实现将实时市场数据保存到数据库，并在需要时进行查询和分析。
相关·内容
使用以下代码将websocket连接到pythonanywhere中的kucoin交换
import websocket
import requests
base_url = 'https://api.kucoin.com'
public_url_request = '/api/v1/bullet-public'
response = requests.post(base_url+public_url_request)
response_json = response.json()
token = response_json['data']
浏览 36提问于2022-04-17得票数 0
我有这个代码来连接到KuCoin网络插座，并接收烛棒数据。我的问题是:如何将消息保存到变量(可能在另一个脚本中)？我想在以后使用这些数据，并将其保存到数据库中，然后使用它进行计算和绘图。 import asyncio
from kucoin.client import WsToken
from kucoin.ws_client import KucoinWsClient
async def kline_msg(msg):
if msg["topic"] == "/market/candles:SLP-USDT_30min":
pri
浏览 51提问于2021-10-15得票数 1
如何获得到Kucoin Exchange的websocket连接？我正在尝试这个密码：
import os
import time, hashlib, requests, base64, hmac, json, websocket, uuid
now = str(int(time.time() * 1000))
token = "my token"
SOCKET = f'wss://push1-v2.kucoin.net/endpoint?token={token}&connectId={now}'
params = {"type"
浏览 13提问于2022-07-21得票数 0
在python-kucoin：的wiki中使用示例代码时
在调试模式下，我继续获取"sleeping to keep loop open" (我正在使用PyCharm)。
在深入研究代码时，我还意识到在代码(res['instanceServers'][0]['endpoint'])：的这个阶段
端点是wss://ws-api.kucoin.com/endpoint
根据库乔因的文档，它应该是：wss://push1-v2.kucoin.com/endpoint
这是意料之中吗？
我强迫代码改变了这一点，但这也无助于接收任何数据.
我应该等待多久
浏览 12提问于2022-01-06得票数 0
我使用kucoin websocket连接到kucoin交换并接收实时数据。
为了接收不同货币的数据，必须使用以下地址(根据与库考因交易相关的文档中的内容)：/contractMarket/level2:XBTUSDM
但是当我更改符号时，例如，ADAUSDM web套接字对我不起作用，它会给我以下消息
websockets.exceptions.ConnectionClosedOK: sent 1000 (OK); then received 1000 (OK)
如果有人能指点我，我将不胜感激
浏览 13提问于2022-07-02得票数 0
5回答
我正在设计一个websocket服务器，它接收消息并将其保存到嵌入式数据库中。用于阅读我正在使用的消息。为了将消息保存到嵌入式数据库，我在前面看到了几个选项：
在同一线程上接收到消息后，立即同步保存它们。
将消息异步保存在单独的线程上。
我很确定第二个答案是我想要的。但是，我不知道如何将消息从套接字线程传递到IO线程。我认为有以下几种选择：
每个线程使用一个io服务，并使用在线程之间进行通信。在这里，我必须担心锁争用。我应该吗？
使用Linux域套接字在线程之间传递消息。据我所知，没有锁定争用。在这里，我可能可以使用BOOST_ASIO_DISABLE_THREADS宏
浏览 6提问于2016-05-24得票数 6
我是一个新的Django程序员。我在Django中用rest_framework编写了一个API调用。当调用此API时，我的程序连接到KUCOIN并获取所有加密货币的列表。我希望保存符号并在数据库中命名此加密货币。为了将数据保存到数据库中，我使用“For循环”，在每次for循环迭代中，我都会查询数据库并保存数据。我的代码：
for currencie in currencies:
name = currencie['name']
symbol = currencie['symbol']
active = (False, True)[sym
浏览 4提问于2022-01-20得票数 1
我是websocket的新手。我目前正在侦听我的node.js中间件应用程序中的websocket。一旦我收到一条消息，我必须将该消息存储在数据库中。
const ws = new WebSocket("ws://localhost:3000");
ws.on("message", (event) => {
console.log("connected to DB");
testConnection();
});
每当接收到新消息时，都应该触发testConnection函数。
async function testConnect
浏览 0提问于2018-11-22得票数 0
WebSockets 向另一端发送pings，而另一端应该用乒乓来响应。
在接收到Ping帧时，端点必须发送Pong帧作为响应，除非它已经收到了一个接近的帧。它应该尽快与乒乓框架作出反应是切实可行的。
以保持活动形式的TCP ：
您向对等方发送一个未包含数据的保活探测包，并打开ACK标志。您可以这样做，因为TCP/IP规范是一种重复的ACK，远程端点将没有参数，因为TCP是面向流的协议。另一方面，您将收到来自远程主机的答复(它根本不需要支持保持活动，只支持TCP/IP)，没有数据和ACK集。
我认为TCP保持活动更有效，因为它可以在内核中处理，而无需将数据传输到用户空间，解析w
浏览 2提问于2014-04-23得票数 103
回答已采纳
我正在尝试从Huobi USDT Swaps中流式传输比特币价格，但我的ping/pong机制不起作用，因此Huobi总是在30秒后关闭连接。 这就是文档中所说的https://huobiapi.github.io/docs/usdt_swap/v1/en/#market-heartbeat WebSocket接口支持双向心跳。Server和Client都可以发送ping报文，对方可以用pong报文返回。 WebSocket服务器发送心跳：{"ping"：18212558000} WebSocket客户端应响应：：{"pong"：18212558000} 注意
浏览 155提问于2021-07-24得票数 0
1回答
我有一个使用WebSocket连接到服务器的脚本
export class AppComponent {
connection_status = false;
message = '';
public connect() {
this.socket = io('http://localhost:5001');
this.socket.on('connected', this.connection_established);
}
}
我想在收到connected消息时更改connection_status变量，并
浏览 4提问于2017-07-25得票数 0
回答已采纳
我有一个带有Redux商店的React应用程序，它连接到一个websocket，并以表格的形式向用户显示信息。我有RxJs中间件，它连接到websocket并用内容分派动作。然后，这些将在减速器中被提取并保存到我的状态。然后我使用mapStateToProps在我的React组件中显示数据。 问题是更新的速度比渲染快。我每秒可以获得50个更新，如果我每次都渲染数据，我的应用程序的性能将会很糟糕。我需要一种方法来限制mapStatetoProps被调用的次数。我有很多映射到这种状态的组件，并且到目前为止，我在shouldComponentUpdate中对每个组件都有1秒的限制。如果我能在较低的
浏览 21提问于2020-06-18得票数 3
2回答
我正在使用Twilio发送和接收来自客户的短信。
每次我发短信给我的客户时，我都会把像to、body这样的功能存储到我的数据库中。
我已经实现了用于发送消息的API，它运行良好，只需将字段保存到我的数据库中。
我的问题
当我收到来自我客户的短信到我的twilio号码。我想得到像from number和body这样的字段，然后保存到我的数据库中。
我看了这里的文件
但这只说明了如何在收到消息时向客户发送响应。
我想把收到的短信保存到我的数据库中。
当收到短信时，有人能帮我拿到from number和message body吗？tnx..。
浏览 4提问于2015-06-03得票数 6
回答已采纳
我正在用NodeJs构建命令行websocket测试。 我在文件的顶部定义了filestream const fs = require('fs');
let writeStream = fs.createWriteStream(log_path); 我正在使用下面的代码来测试websocket，但我在尝试写入文件流时遇到错误。 async function test(...) {
const websocket = new WebSocket(wsUrl)
await connection(websocket)
websocket.send
浏览 42提问于2020-12-08得票数 1
我最近开始学习websockets，并且我决定尝试学习和使用Python的framweork旋风来创建我的简单测试项目(没有什么特别的，只是一些基本的项目，它可以帮助我了解一些关于龙卷风和websockets的东西)。
所以，这就是我的想法(工作流)：
1)我从其他应用程序收到http post请求到我的服务器(例如，关于某人姓名和电子邮件的信息)
2)将接收到的数据保存到postgresql数据库，并通知监听器(发布/订阅)新数据已添加到数据库
3)收到通知后，服务器应向客户端发送消息(write_message方法)。
这是我现在的代码
simple_server.py
import to
浏览 1提问于2014-01-09得票数 1
回答已采纳
我有一个websocket客户端，每秒从websocket流接收200-300条消息。接收消息的JavaScript客户机正在对接收到的每条消息执行一些DOM操作。我担心在浏览器中运行应用程序几分钟后，消息的处理可能会落后。就像聊天应用程序被收到的消息淹没，一段时间后，接收websocket消息和向用户显示消息之间的延迟会越来越长……另一个例子是实时股票市场页面，但在打开几分钟后，实时价格就不再是实时的了……
如何确定浏览器是否与传入的websocket消息保持同步？
更新
我最终让页面上的每条消息都更新了一个时钟，看看它是否落后了：
function onMessage(evt)
{
v
浏览 0提问于2018-02-03得票数 0
目前，我们有一个api端点，它通过ID请求单个“Group”。
我们设置了一个WebSocket订阅，在onCacheEntryAdded定义中，我们处理该组被更新或删除的情况。
当我们收到来自websocket的更新消息时，我们触发以下内容；
updateCachedData((draft) => {
draft = response;
}
如预期的那样更新条目。
但是，如果我们想要完全删除条目，我们应该使用什么方法？在删除websocket中的消息时，我假设我可以简单地将草案设置为未定义的，但情况似乎并非如此。
浏览 2提问于2022-05-09得票数 0
回答已采纳
1回答
导轨推送电磁插座
、、、
我正在编写rails应用程序，我希望用户在新消息保存到DB后立即收到通知。对于websocket，我使用em-websocket宝石。连接后，我将客户端id和套接字实例存储在数组中。
问:如何从控制器\模型操作(例如before_save)将数据推送到客户端？它能用em-websocket来实现吗？
chat.rb
EVENTCHAT_CONFIG = YAML.load_file("#{Rails.root}/config/eventchat.yml")[Rails.env].symbolize_keys
#escape html/xss
include ERB::Util
浏览 2提问于2015-12-04得票数 0
我有这个Redis Gist，它基本上只是sinatra-websocket github页面的示例，并粘贴了一些代码。那部分
settings.redis.subscribe 'foobar' do |on|
on.message do |channel, message|
settings.sockets.each do |s|
s.send message
end
end
end
正在阻止Sinatra应用程序正确启动aus subscribe正在阻止。我通过将订阅放入ws.onopen处理程序中取得了小小的成功，但这将覆盖每个新的we
浏览 0提问于2013-04-19得票数 0
1回答
Python类之间的异步通信
、、、、
我实现了一个连接到websocket以接收异步消息的类。
class websocketClient(...):
def on_message(self, msg): # Gets automatically called
notifyBrokerAbout(msg) # How to proceed from here?
class Broker():
self.websocket = websocketClient(...)
self.websocket.start()
def heartbeat(self):
ret
浏览 26提问于2018-06-24得票数 1
我想了解您的想法，我如何通过能够在多个服务器上运行我的服务进程来实现水平扩展。它是一个用C#编写的Windows服务，它的实际用途是订阅我们公司的Exchange Web service (EWS)，这样每当有新的电子邮件传入时，它就会得到通知(通过HTTP回调)。然后，该服务获取电子邮件消息，对其进行处理，如果可能，发送回复，然后返回睡眠状态并等待下一封传入的电子邮件。
如果我在多台机器上运行它，我可以让所有机器都订阅EWS通知，也可以只让其中一台机器订阅。如果我让所有人都订阅，我会有点犹豫，因为这可能会给我们的MS Exchange基础结构增加负担。此外，这将导致所有机器接收和处理电子邮件
浏览 2提问于2014-03-27得票数 1
2回答
在使用队列时跳过SQS消息
、、、、
我有一个消息生成器，将像{"user_id": 1, "message": "Ciao"}这样的消息发送到SQS队列。
我有三个Websocket实例，它们的名称是A、B和C。
假设有五个用户连接到该API，其ID为1、2、3、4和5。
每个用户都连接到API，而我的平衡器(粘性ofc)使客户端以这样的方式连接到API：
A: 1, 3
B: 5
C: 2, 4
现在，Websocket是上面提到的SQS队列的使用者。
当我为用户1登记消息时，任何使用者都可以先排掉它的队列，比如说C。
实例C不能对user_id 1的消息执行任何操作。A确实保存
浏览 2提问于2021-11-18得票数 0
回答已采纳
1回答
棘轮多服务器
、、
在我的PHP应用程序中，我使用棘轮()作为websockets。我有多台虚拟机运行应用程序，这些机器中的每一台都承载websocket服务。请求通过HAProxy传递到这些虚拟机之一。目前，用户在它为应用程序连接的同一节点上使用websocket服务。
现在，我对websocket服务器之间的讨论有了一个问题。例如：
user1连接node1，user2连接node2
User1通过websocket向user2发送websocket消息。
User2从未收到此消息，因为他已连接到另一个节点。
做这种消息传递的良好实践是什么？我有一些想法，但不知道该怎么做：
每个客户端
浏览 1提问于2015-02-12得票数 6
1回答
我已经成功地连接到Bitstamp websocket，现在我正在尝试索引我收到的数据流。具体地说，我希望将出价保存到best_price变量中：
{'data': {'timestamp': '1615553987', 'microtimestamp': '1615553987492634', 'bids': [['56355.57', '0.09439734'], ['56347.20', '0.03743896'], ['
浏览 14提问于2021-03-12得票数 0
如何将通过WebSocket二进制消息接收的blob转换为Float32Array (或其他类型的数组: Uint32、Uint16等)。
我试过使用FileReader，但“结果”花了很长时间才可用。结果必须在下一条收到的WebSocket消息中可用。
如果我能让WebSocket接收一个ArrayBuffer而不是Blob，那就行了。我该怎么做呢？
浏览 5提问于2017-02-26得票数 2
1回答
我试着设置这个例子，，这是我的代码
App.factory('MyData', function($websocket, $q) {
var dataStream = $websocket('wss://url');
var collection = [];
dataStream.onMessage(function(message) {
var result = JSON.parse(message.data);
console.log(result);
collection = result;
});
var methods =
浏览 2提问于2017-02-01得票数 0
回答已采纳
1回答
我已经了解了如何发布消息到SNS主题和订阅是移动通知。
但我也希望每条消息都保存到数据库中。我怎么能这么做？
因为我知道您也可以订阅sqs队列到相同的主题。但我不仅想保存这条信息，还想让谁收到这条消息。
谁能帮我做些合乎逻辑的事吗？
谢谢！:)
浏览 4提问于2022-03-18得票数 0
回答已采纳
1回答
我正在尝试使用VS Community 2015在c#中编写一个android应用程序，该应用程序应该向websocket发送一条消息，显示它收到的答案。
这是我的MainActivity.cs
public class MainActivity : Activity
{
protected override void OnCreate(Bundle bundle)
{
base.OnCreate(bundle);
// Set our view from the "main" layout resource
浏览 0提问于2016-02-29得票数 0
我试着用Go学习websockets。我一直在看大猩猩websocket的例子。
我已经检查了以下两个示例，这些示例演示了如何使用大猩猩websocket：
所有这些示例都显示了如何连接到websocket服务器、发送和接收文本。但我不明白的是你怎么能只发送给一个客户。因为在实际应用程序中，您将有用户，我们不希望所有用户接收相同的消息和数据。是否有一种方法可以获得连接的唯一id，可以保存在数据库中，如redis，并将其链接到同一数据库中的用户id，然后使用该websocket id发送回特定的客户端(如果用户id收到消息或通知)？这样一个人才能实现这样的目标吗？如果是这样的话，我怎么会这样
浏览 2提问于2015-07-23得票数 4
我对websocket连接有问题。这是浏览器中的错误。就在我刷新页面的时候，我在pusher.com中收到了一条消息，但不是每次websocket连接时都是这样。我认为我的.env文件有问题，但不确定。
.env文件：
PUSHER_APP_ID=...
PUSHER_APP_KEY=...
PUSHER_APP_SECRET=...
PUSHER_HOST=null
PUSHER_PORT=443
PUSHER_SCHEME=https
PUSHER_APP_CLUSTER=eu
我应该写什么主机来解决这个问题？还是问题出在别的地方？
浏览 11提问于2022-09-06得票数 1
回答已采纳
如何检查服务器的XON/XOFF，检查套接字是否处于活动状态。TCP半封闭存在一个问题，即发送数据但服务器没有通过活动接收数据。它每2分钟发送一次XON/XOFF，如果我没有收到任何信号，有什么方法可以检测到并重新连接吗？
浏览 4提问于2011-11-18得票数 0
回答已采纳
我不熟悉Windows phone 7推送通知。我能够在我的手机中发送和接收瓷砖和吐司通知。然而，我的问题是，我想将所有这些通知保存到windows phone7的本地数据库中。
当应用程序运行时，如果toast消息到达，我可以捕获该事件，我们可以将数据保存到本地数据库，这很好。
但是，如果应用程序没有运行，并且我收到一条toast消息，我需要将该消息保存到本地数据库。我找不到解决这个问题的方法。请帮帮我。
浏览 1提问于2012-05-02得票数 2
我试图使用Websocket和total.js将数据传递给Mongodb。在我的homepage.html中，我可以在单击“保存”按钮后通过websocket获取用户输入并连接到服务器。
在default.js中是我的服务器端代码。此时，应用程序帽子获得用户输入并正确连接到服务器，但现在如何将数据保存到mongodb？
这是我的homepage.html
<br />
<div>
<input type="text" name="message" placeholder="Service" maxlength=
浏览 2提问于2014-10-14得票数 0
2回答
我是一个编程新手，有必要编写用JMeter进行负载测试的程序，因为我找不到现有的GUI工具来执行我想做的事情。
我试图通过使用WebSocket插件“”来加载测试一个应用程序。
我需要建议如何处理从WebSocket服务器发送的消息。
这里有一些条件。
在与WebSocket服务器建立连接之后，服务器将以任意时间发送JMeter消息。
当JMeter收到消息时，它必须返回消息才能通知接收消息。
基于来自服务器的消息内容，JMeter必须修改局部变量。
下面是我当前的JMeter配置概述。
使用对接收消息和发送消息的线程进行划分。
在接收消息线程时，我尝试在空的采样器
浏览 0提问于2018-09-11得票数 0
我正试着开发某种通讯应用。每次收到消息时，我都会将它与消息发送方和消息正文一起保存到SQLite数据库中。
这是流程，
我收到一个号码的消息
检查我手机的联系人中是否存在这个号码
使用以下字段( contact_name、message_body )将消息保存在我的DB上
现在的问题是，当某个联系人在我的应用程序之外更新它的名称时，我如何跟踪或告诉我的应用程序在我的应用程序内的DB上更新这个名称。
谢谢!
浏览 1提问于2015-09-24得票数 0
所以我在消费者中有我的websocket，我在消费者中做了，当websocket收到它时，它会在我的模型中更新为+1 a FloatField，问题是我不知道为什么不能工作，这是我的代码：
models.py：
from django.contrib.auth.models import User
from django.db import models
from django.conf import settings
from django.utils.translation import gettext_lazy as _
class ProfileImage(models.Model)
浏览 0提问于2020-08-10得票数 1
我在服务器上运行了一个API，它处理用户连接和消息传递系统。
除此之外，我还在同一台服务器上启动了一个websocket，等待连接和其他东西。
比方说，我们可以通过Android应用程序访问这个系统。
我很难弄清楚我现在该做什么，以下是我的想法：
当用户连接到应用程序时，API连接到websocket。我们只允许Android应用程序监听这个套接字来获取新消息。当用户想要回答时，Android应用程序会向API发送一条消息。API将接收到的消息写入套接字，该套接字将被另一个用户使用的Android应用程序读取。这样，API可以在将消息写入套接字之前将消息存储在数据库中。
2- API不以任何方
浏览 1提问于2016-05-15得票数 0
回答已采纳
我正在编写一种聊天服务器应用程序，其中从一个websocket客户端接收到的消息被发送到所有其他websocket客户端。为此，我将连接的客户端保存在一个列表中。当客户端断开连接时，我需要将它从列表中删除(这样以后的“发送”就不会失败)。
然而，有时当客户端断开连接时，服务器只会收到一个异常"connection reset by peer"，并且代码没有机会从客户端列表中删除。有没有办法保证“很好”的通知连接已经被重置？
我的代码是：
void WsRequestHandler::handleRequest(HTTPServerRequest &req, HTTPSe
浏览 9提问于2013-11-18得票数 1
我在react中使用websocket。以下是组件的代码： import React, { useState, useEffect } from "react";
export default function Component(props) {
const [socket, setSocket] = useState();
const parseMessage = (msg) => {
if (msg[0] !== "R") sendMessage("123"); // ignore the very first
浏览 222提问于2021-09-20得票数 2
回答已采纳
我将尝试用一个例子来解释我正在做什么，比如我正在构建一个天气客户端。浏览器通过websocket发送消息，例如：
{
"city": "Chicago",
"country": "US"
}
服务器每5分钟查询一次天气，并用最新数据更新浏览器。
现在浏览器可以发送另一条消息，例如：
{
"city": "Bangalore",
"country": "IN"
}
现在，服务器应该停止更新芝加哥的天气详细信息，并开始更新有关班加罗尔的详细信息，即同时通过
浏览 134提问于2021-06-12得票数 2
回答已采纳
我已经设置了一个nodejs websocket AWS lambda端点(Api Gateway)，它可以连接并回显消息。在初始连接期间，我将端点和connection_id保存到数据库中。这样就能得救了。如果我打开一个浏览器客户端，并连接到websocket端点，我可以成功地连接，并成功地从浏览器发送一条消息-我有代码回显消息，而且它可以工作。
现在，在另一个提供REST端点的nodejs中，我有从数据库加载connection_id的代码，并执行以下操作：
// 'connection' is loaded successfully from DB (I log it a
浏览 2提问于2019-07-14得票数 3
我有以下连接到websockets的代码
class Connection < AbstractConnection
def initialize
@conn = WebSocket::Client::Simple.connect @url
@conn.on :message do |event|
puts 'received message'
#this is the weird part
puts self
event_data = event.data.to_json
on_mes
浏览 3提问于2015-04-02得票数 2
回答已采纳
每次我尝试将某些内容保存到数据库中时，都会收到此错误消息。我看到Heroku为前10.000条记录提供了免费的PostgreSQL数据库，超过10.000条记录是需要为数据库付费的。
现在，我的数据库里大概有60.000条记录。如何修复错误/升级数据库？
提前谢谢你
浏览 0提问于2012-11-20得票数 9
回答已采纳
我试图在php中创建一个函数，该函数可以将unix_timestamp保存到mysql数据库中，但我一直收到有关无效参数号的错误消息。
这是函数的代码：
function addNew($array){
$sql = 'INSERT INTO USER (id, acronym, name, password)
VALUES (?, ?, ?, UNIX_TIMESTAMP());';
$id = isset($_POST['id']) ? $_POST['id'] : null;
$acronym = isset($_POST[
浏览 1提问于2014-04-25得票数 2
我试图在nodejs中实现一个websocket实时聊天系统。我已经有一个登录系统和websocket聊天系统。我唯一坚持的就是将消息保存到MySQL，以便用户可以访问他们的聊天历史记录。问题是，我不想发送一个网络套接字消息给收件人，然后让MySQL插入失败的原因。
一种可能的解决方案：显而易见的解决方案是将消息数据保存在MySQL中，然后将web消息发送给收件人。如果有错误，请将其发送回发送方，而不是发送消息。但是，如果服务器必须等待MySQL插入成功确认，这难道不违背web套接字的用途吗？
浏览 3提问于2017-04-02得票数 0
回答已采纳
有人能帮我怎么做吗？每次收到消息时，我都想将消息从websocket传递到串口。
var firmata = require('firmata');
var board = new firmata.Board('COM4');
var WebSocketServer = require('ws').Server;
var wss = new WebSocketServer({ port: 8081 });
wss.on('connection', function connection(websocket) {
web
浏览 0提问于2015-05-05得票数 2
回答已采纳
在相对安静的服务器上使用WebSocket4Net客户端打开WebSocket。4分钟后，套接字将收到一条关闭消息。4分钟后，如果套接字上未收到其他消息活动，则套接字将收到一条关闭消息。
WebSocket中是否定义了超时？我正在尝试确定WebSocket是否因超时而关闭，因为服务器没有设置活动超时，因此将允许套接字无限期地保持连接。
浏览 4提问于2012-11-21得票数 4
我正在使用Angular2 (r.2.0.0)和typescript (v.1.8.10)。工作时滚动Chrome什么也不做并给出警告(由于主线程繁忙，‘鼠标滚轮’输入事件的处理被延迟了236毫秒。考虑将事件处理程序标记为“被动”，以使页面更具响应性。)
我正在使用websocket消息，滚动时无法触发收到的消息。当滚动作业完成后，所有收到的消息都将开始处理。我发现了类似的问题，但它没有解决我的问题。
html代码：
<canvas id="{{ReferenceLineCanvasName}}" (mousewheel)="OnMouseWheel($event
浏览 1提问于2016-10-12得票数 1
我正在尝试创建一个Python脚本，它将从websocket连接接收消息，每次它接收到新消息时，它都需要在后台运行一个异步任务。 为了“模拟”这个过程，我做了一个阻塞函数，它用一条while True语句开始计数。预期的输出是，每次从ws连接接收到新消息时，都会启动一个新的计数，但在我的示例中，只要我一运行脚本，count函数就会阻塞整个代码。我该如何解决这个问题呢？ 这是我尝试过的： import asyncio
import websockets
import json
import time
#this is the blocking function..
def counter()
浏览 68提问于2021-11-10得票数 2
回答已采纳
我正在为特定设备编写自动UI测试，其中UI配置从后端服务器作为多个JSON文件通过websocket连接传输到设备。首先，我编写了一个单独的小脚本，它接收websocket消息，将它们保存到JSON文件中，并关闭websocket连接。然后，当我在另一个文件中运行测试时，我可以访问JSON文件并处理测试中的配置信息。
然而，我想要做的是在测试中集成这个websocket连接，所以我只会运行一个测试，它将处理所有的事情。我试过这样做，但是测试被困在听websocket，它不能在UI中导航，这是测试中的下一个步骤，它将触发消息传输。
我正在使用Python2.7.14在Anaconda虚拟环境中运
浏览 0提问于2018-07-06得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
