websocket 结合 mysql 代码案例
时间: 2023-11-21 17:07:29 浏览: 28
以下是一个简单的代码示例，展示如何使用WebSocket与MySQL进行交互：
server.js
```javascript
const WebSocket = require('ws');
const mysql = require('mysql');
const dbConnection = mysql.createConnection({
host: 'localhost',
user: 'root',
password: 'password',
database: 'mydatabase'
});
dbConnection.connect();
const server = new WebSocket.Server({ port: 8080 });
server.on('connection', (socket) => {
console.log('Client connected.');
socket.on('message', (message) => {
console.log(`Received message: ${message}`);
const query = `SELECT * FROM mytable WHERE id = ${message}`;
dbConnection.query(query, (error, results, fields) => {
if (error) {
socket.send(JSON.stringify({ error: error }));
} else {
socket.send(JSON.stringify({ data: results }));
}
});
});
socket.on('close', () => {
console.log('Client disconnected.');
});
});
```
client.html
```html
<!DOCTYPE html>
<html>
<head>
<title>WebSocket and MySQL Demo</title>
</head>
<body>
<h1>WebSocket and MySQL Demo</h1>
<label for="id-input">Enter ID:</label>
<input id="id-input" type="text">
<button id="query-button">Query</button>
<p id="result"></p>
<script>
const socket = new WebSocket('ws://localhost:8080');
socket.addEventListener('open', (event) => {
console.log('Connected to server.');
});
document.getElementById('query-button').addEventListener('click', () => {
const id = document.getElementById('id-input').value;
socket.send(id);
});
socket.addEventListener('message', (event) => {
const data = JSON.parse(event.data);
if (data.error) {
document.getElementById('result').innerHTML = `Error: ${data.error}`;
} else {
document.getElementById('result').innerHTML = JSON.stringify(data.data);
}
});
socket.addEventListener('close', (event) => {
console.log('Disconnected from server.');
});
</script>
</body>
</html>
```
当客户端连接到服务器时，它会显示一个输入框和一个按钮。当用户点击按钮时，它会发送一个包含所输入ID的WebSocket消息。服务器会将该消息用作查询条件，从MySQL数据库中检索数据，并将结果作为JSON消息发送回客户端。客户端显示结果或错误消息。
相关推荐
最新推荐
Vue通过WebSocket建立长连接的实现代码
主要介绍了Vue通过WebSocket建立长连接的实现代码，文中给出了问题及解决方案,需要的朋友可以参考下
微信小程序通过websocket实时语音识别的实现代码
主要介绍了微信小程序通过websocket实时语音识别，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
Uniapp使用GoEasy实现websocket实时通讯
Uniapp作为近来最火的移动端开发技术，一套代码，可以打包成Android/iOS app和各种平台的小程序，可谓是没有最方便只有更方便。 GoEasy上架DCloud Uniapp插件市场已经有一个多月了，收到很多Uniapp开发人员的赞扬和...
C#实现WebSocket协议客户端和服务器websocket sharp组件实例解析
主要介绍了C#实现WebSocket协议客户端和服务器websocket sharp组件实例解析,包括websocket sharp组件的概念及使用方法，需要的朋友可以参考下
Spring WebSocket 404错误的解决方法
主要为大家详细介绍了Spring WebSocket 404错误的解决方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
zigbee-cluster-library-specification
最新的zigbee-cluster-library-specification说明文档。
管理建模和仿真的文件
管理Boualem Benatallah引用此版本：布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学，1996年。法语。NNT：电话：00345357HAL ID：电话：00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆，用于存放和传播科学研究论文，无论它们是否被公开。论文可以来自法国或国外的教学和研究机构，也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
实现实时数据湖架构：Kafka与Hive集成
# 1. 实时数据湖架构概述**
实时数据湖是一种现代数据管理架构，它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同，实时数据湖不依赖于预先定义的模式，而是采用灵活的架构，可以处理各种数据类型和格式。这种架构为企业提供了以下优势：
- **实时洞察：**实时数据湖允许企业访问最新的数据，从而做出更明智的决策。
- **数据民主化：**实时数据湖使各种利益相关者都可
可见光定位LED及其供电硬件具体型号，广角镜头和探测器，实验设计具体流程步骤，
1. 可见光定位LED型号：一般可使用5mm或3mm的普通白色LED，也可以选择专门用于定位的LED，例如OSRAM公司的SFH 4715AS或Vishay公司的VLMU3500-385-120。
2. 供电硬件型号：可以使用常见的直流电源供电，也可以选择专门的LED驱动器，例如Meanwell公司的ELG-75-C或ELG-150-C系列。
3. 广角镜头和探测器型号：一般可采用广角透镜和CMOS摄像头或光电二极管探测器，例如Omron公司的B5W-LA或Murata公司的IRS-B210ST01。
4. 实验设计流程步骤：
1）确定实验目的和研究对象，例如车辆或机器人的定位和导航。
JSBSim Reference Manual
JSBSim参考手册，其中包含JSBSim简介，JSBSim配置文件xml的编写语法，编程手册以及一些应用实例等。其中有部分内容还没有写完，估计有生之年很难看到完整版了，但是内容还是很有参考价值的。