Express全系列教程之(九)：将session上传至mysql数据库

谁践踏了优雅 2023-07-18 02:52 69阅读 0赞

# 一、简介 #

实际引用中，有些公司在不同地区会设置不同服务器，因此就需要用到nginx以实现负载均衡，这时，将session数据保存至数据库就成为了需要面对的问题，我们以MySQL数据库为例，看看他是如何将数据上传至mysql中的。  
在npm上有一个叫做：express-mysql-session的模块，主要用于将数据上传至mysql数据库，以下为他的实现方式：

session story会在内部创建一个MySQL连接池，用于处理数据库的连接。  
数据库连接池由于可以实现连接复用，避免了数据库连接频繁建立、关闭的开销。默认情况下，连接池由1个连接组成，但可以使用connectionlimit选项覆盖此连接。你也可以设置额外的连接池option选项。

**当使用默认选项时，存储session数据库的表会被自动创建；**

# 二、通过一个实例说明： #

1.首先在数据库中我们需要有一个存储数据的数据库：

![format_png][]

2.安装以下模块：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 </td> 
 <td> <code>const express=require(</code><code>"express"</code><code>);</code> <code>const mysql=require(</code><code>"mysql"</code><code>);</code> <code>const cors=require(</code><code>"cors"</code><code>);&nbsp;</code><code>//处理跨域</code> <code>const session=require(</code><code>"express-session"</code><code>);</code> <code>const MySQLStore=require(</code><code>'express-mysql-session'</code><code>)(session);&nbsp;</code><code>//连接mysql主要模块</code> </td> 
 </tr> 
 </tbody> 
</table>

3.键入如下代码即可上传至mysql数据库：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 </td> 
 <td> <code>const express=require(</code><code>"express"</code><code>);</code> <code>const mysql=require(</code><code>"mysql"</code><code>);</code> <code>const cors=require(</code><code>"cors"</code><code>);</code> <code>const session=require(</code><code>"express-session"</code><code>);</code> <code>const MySQLStore=require(</code><code>'express-mysql-session'</code><code>)(session);</code> &nbsp; <code>var</code>&nbsp;<code>app=express();</code> &nbsp; <code>// 配置mysql</code> <code>var</code>&nbsp;<code>options = { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>host:&nbsp;</code><code>'localhost'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>port: 3306,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>user:&nbsp;</code><code>'root'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>password:&nbsp;</code><code>'123456'</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>database:&nbsp;</code><code>'session'</code> <code>};</code> &nbsp; <code>var</code>&nbsp;<code>sessionConnection = mysql.createConnection(options);</code> <code>var</code>&nbsp;<code>sessionStore =&nbsp;</code><code>new</code>&nbsp;<code>MySQLStore({ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>expiration: 10800000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>createDatabaseTable:&nbsp;</code><code>true</code><code>,&nbsp;&nbsp;</code><code>//是否创建表</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>schema: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>tableName:&nbsp;</code><code>'session_tab'</code><code>,&nbsp;&nbsp;&nbsp;</code><code>//表名</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>columnNames: {&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//列选项</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>session_id:&nbsp;</code><code>'session_id'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>expires:&nbsp;</code><code>'expires'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>data:&nbsp;</code><code>'data'</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}, sessionConnection);</code> &nbsp; <code>//配置中间件</code> <code>app.use(session({ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>key:&nbsp;</code><code>'aid'</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>secret:&nbsp;</code><code>"keyboard cat"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>store: sessionStore,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>resave:&nbsp;</code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>saveUninitialized:&nbsp;</code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cookie: (</code><code>'name'</code><code>,&nbsp;</code><code>'value'</code><code>,{&nbsp; maxAge:&nbsp; 5*60*1000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>secure:&nbsp;</code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>name:&nbsp;</code><code>"seName"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>resave:&nbsp;</code><code>false</code><code>})</code> <code>}));</code> &nbsp; <code>app.use(cors());</code> &nbsp; <code>app.use(</code><code>'/login'</code><code>,</code><code>function</code><code>(req,res){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//设置session</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>req.session.userinfo=</code><code>'张三'</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>res.send(</code><code>"登陆成功！"</code><code>);</code> <code>});</code> &nbsp; <code>app.use(</code><code>'/loginOut'</code><code>,</code><code>function</code><code>(req,res){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//注销session</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>req.session.destroy(</code><code>function</code><code>(err){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>res.send(</code><code>"退出登录！"</code><code>+err);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>});</code> &nbsp; <code>app.use(</code><code>'/'</code><code>,</code><code>function</code><code>(req,res){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//获取session</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code><code>(req.session.userinfo){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>res.send(</code><code>"hello "</code><code>+req.session.userinfo+</code><code>"，welcome to index"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code><code>else</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>res.send(</code><code>"未登陆"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>});</code> &nbsp; <code>app.listen(8080);</code> </td> 
 </tr> 
 </tbody> 
</table>

这时启动我们的服务器：

![format_png 1][]

进入http://localhost:8080/时显示未登录：

![format_png 2][]

重新连接如mysql：

![format_png 3][]

![format_png 4][]

我们可以看到，这时session自动创建了session\_tab表，但表上并没有相应的名称，只有配置信息，接下来在浏览器中进入login路由：

![format_png 5][]

我们只需重连mysql数据库，就可看到关于用户信息也有了：

![format_png 6][]

当浏览器进入loginOut路由后，会执行req.session.destroy操作，将session销毁，而数据库表中的用户信息也将销毁：

![format_png 7][]

重连数据库后：

![format_png 8][]

当然大家也可根据自己的实际需求来发挥，这里不在进行更多阐述。

[format_png]: /images/20230528/c0a6a5a7bdb3450183f6b14328242ef7.png
[format_png 1]: /images/20230528/606b34539ca5439aa375bb370ba3327e.png
[format_png 2]: /images/20230528/120341b36ce74179a709776b8fe58fd8.png
[format_png 3]: /images/20230528/1a6e491378cb4aad880278a78f709d9a.png
[format_png 4]: /images/20230528/62d42792201542fba174e1fc58a1b1a7.png
[format_png 5]: /images/20230528/779cde14a475439ab0b89d5518fb4a03.png
[format_png 6]: /images/20230528/02d0c5baba4d4b4e8914e8868709fd4f.png
[format_png 7]: /images/20230528/7d6ed869e7e3433a802b5381b3afb82e.png
[format_png 8]: /images/20230528/afbe5337ba35481ab8eaee4ee07e3075.png