DBUtils连接池,websocket使用

1.mysql数据库连接池

概念:数据库连接池(Connection pooling)是程序启动时建立足够的数据库连接,并将这些连接组成一个连接池,由程序动态地对池中的连接进行申请,使用,释放。

   这样集中管理,供程序使用可以保证较快的数据读写速度,而且不用来回创建数据库连接,节省了时间,也更加的安全可靠。

1.1 背景

  所有线程都只用一个mysql连接,如果这个连接断掉,程序也会出现问题

  如果我们在每次执行一个sql语句的时候都建立一个mysql连接,执行完就关掉,那么可以想象频繁开关这样很容易消耗我们的资源,而且增加了连接失败的几率

1.2 优势

  数据库连接池优势:减少链接次数,此外支持并发

原理:

参考链接:猛戳此处

1.在程序创建连接的时候,可以从一个空闲的连接中获取,不需要重新初始化连接,提升获取连接的速度
2.关闭连接的时候,把连接放回连接池,而不是真正的关闭,所以可以减少频繁地打开和关闭连接

2. DBUtils连接池

  在python中,我们可以通过安装DButils,来实现数据库连接池的功能,它是一个第三方包

  DButils主要作用在于提升mysql的执行效率,当然这种情况下需要结合pymsql来使用

2.1常规操作pymsql

import pymysql

conn = pymysql.connect(host=‘localhost‘,port=3306,user=‘root‘,
                       password=‘‘,database=‘bbb‘,charset=‘utf8‘)

cursor = conn.cursor()
sql = "insert into bbb(id,name) value (‘%s‘,‘%s‘)" % ("5","打算")
cursor.execute(sql)
conn.commit()

cursor.close()
conn.close()

我在我的bbb数据库中的bbb表添加了一条数据,以上是我们的常规操作。针对数据量的大情况下,这种操作方式就不在合适了

2.2 操作数据库连接池

创建数据库连接池

import pymysql
from DBUtils.PooledDB import PooledDB

POOL = PooledDB(
    creator=pymysql,    # 使用连接数据库的模块
    maxconnections=6,   # 连接池允许的最大连接数,0和None表示不限制连接数
    mincached=2,        # 初始化时,连接池中至少创建的空闲的链接,0表示不创建
    maxcached=5,        # 链接池中最多闲置的链接,0和None表示不限制
    maxshared=3,        # 链接池中最多共享的链接数量,0和None表示全部共享。
    # PS: 无用,因为pymysql和MySQLdb等模块的 threadsafety都为1,所有值无论设置为多少,_maxcached永远为0,所以永远是所有链接都共享。
    blocking=True,      # 连接池中如果没有可用连接后,是否阻塞等待。True,等待;False,不等待然后报错
    maxusage=None,      # 一个链接最多被重复使用的次数,None表示无限制
    setsession=[],      # 开始会话前执行的命令列表。如:["set datestyle to ...", "set time zone ..."]
    ping=0,             # ping MySQL服务端,检查是否服务可用。
                #  如:0 = None = never,
                # 1 = default = whenever it is requested,
                # 2 = when a cursor is created,
                # 4 = when a query is executed,
                #  7 = always
    host=‘127.0.0.1‘,
    port=3306,
    user=‘root‘,
    password=‘‘,
    database=‘bbb‘,
    charset=‘utf8‘
)

使用数据路连接池

def func():
    # 检测当前正在运行连接数的是否小于最大链接数,如果不小于则:等待或报raise TooManyConnections异常
    # 否则
    # 则优先去初始化时创建的链接中获取链接 SteadyDBConnection。
    # 然后将SteadyDBConnection对象封装到PooledDedicatedDBConnection中并返回。
    # 如果最开始创建的链接没有链接,则去创建一个SteadyDBConnection对象,再封装到PooledDedicatedDBConnection中并返回。
    # 一旦关闭链接后,连接就返回到连接池让后续线程继续使用。
    conn = POOL.connection()

    cursor = conn.cursor()
    cursor.execute(‘select * from bbb‘)
    result = cursor.fetchall()
    print(result)
    cursor.close()
    conn.close()

func()

效果:

数据路连接池详细介绍:猛戳此处

3.websocket

3.1介绍:

  WebSocket是一种在单个TCP连接上进行全双工通信的协议。WebSocket通信协议于2011年被IETF定为标准RFC 6455,并由RFC7936补充规范。WebSocket API也被W3C定为标准。  ---->维基百科

socke与websocket区别:

  socket:位于网络层级的传输层,它是对TCP,UDP的封装

  websocket:它常与http协议作比较

        WebSocket常见于客户端-服务端全双工的场景,客户端可以发送消息给服务端,同时服务端也可以主动发送消息给客户端。

        而Http是单向的关系,只能客户端发送请求,服务端被动接收,服务端没有主动发起对话的能力。

websocket作用:

    WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据

    在 WebSocket API 中,浏览器和服务器只需要完成一次握手,两者之间就直接可以建立持久性的连接,并进行双向数据传输

 websocket优势:

    建立在 TCP 协议之上

    与 HTTP 协议有着良好的兼容性。默认端口也是80和443,并且握手阶段采用 HTTP 协议,因此握手时不容易屏蔽,能通过各种 HTTP 代理服务器

    数据格式比较轻量,性能开销小,通信高效

    可以发送文本,也可以发送二进制数据

    没有同源限制,客户端可以与任意服务器通信

    协议标识符是ws(如果加密,则为wss),服务器网址就是 URL

3.2 websocket客户端    

创建websocket对象:

var Socket = new WebSocket(url, [protocol] );
# 第一个参数 url 指定连接的URL。第二个参数 protocol可选,指定可接受的子协议。

websocket对象属性:

Socket.readyState
# 只读属性readyState表示连接状态,可以是以下值:0 - 表示连接尚未建立。1 - 表示连接已建立,可以进行通信。2 - 表示连接正在进行关闭。3 - 表示连接已经关闭或者连接不能打开

Socket.bufferedAmount
# 只读属性bufferedAmount已被 send() 放入正在队列中等待传输,但是还没有发出的 UTF-8 文本字节数

websocket对象事件:

Socket.onopen             # 连接建立时触发
Socket.onmessage        # 客户端接收服务端数据时触发
Socket.onerror            # 通信发生错误时触发
Socket.onclose            # 连接关闭时触发                

websocket对象相关方法:

Socket.send()    # 使用连接发送数据
Socket.close()    # 关闭连接

实例:

// 初始化一个 WebSocket 对象
var ws = new WebSocket("ws://localhost:9998/echo");

// 建立 web socket 连接成功触发事件
ws.onopen = function () {
  // 使用 send() 方法发送数据
  ws.send("发送数据");
  alert("数据发送中...");
};

// 接收服务端数据时触发事件
ws.onmessage = function (evt) {
  var received_msg = evt.data;
  alert("数据已接收...");
};

// 断开 web socket 连接成功触发事件
ws.onclose = function () {
  alert("连接已关闭...");
};

3.2 websocket服务端

  服务端我们可以利用Node.js、Java、C++、Python等多种语言实现

3.3 基于websocket实现的群聊

3.3 基于websocket实现的单聊

阮一峰博客websocket介绍:参考此处

原文地址:https://www.cnblogs.com/LearningOnline/p/9603642.html

时间: 2024-07-30 02:58:08

DBUtils连接池,websocket使用的相关文章

【JAVAWEB学习笔记】10_JDBC连接池&DBUtils

使用连接池改造JDBC的工具类: 1.1.1          需求: 传统JDBC的操作,对连接的对象销毁不是特别好.每次创建和销毁连接都是需要花费时间.可以使用连接池优化的程序. * 在程序开始的时候,可以创建几个连接,将连接放入到连接池中.用户使用连接的时候,可以从连接池中进行获取.用完之后,可以将连接归还连接池. 1.1.2          分析: 1.1.2.1             技术分析: [自定义连接池](了解) * SUN公司提供了一个连接池的接口.(javax.sql.

Java Web(十) JDBC的增删改查,C3P0等连接池,dbutils框架的使用

前面做了一个非常垃圾的小demo,真的无法直面它,菜的抠脚啊,真的菜,好好努力把.菜鸡. --WH 一.JDBC是什么? Java Data Base Connectivity,java数据库连接,在需要存储一些数据,或者拿到一些数据的时候,就需要往数据库里存取数据,那么java如何连接数据库呢?需要哪些步骤? 1.注册驱动 什么是驱动? 驱动就是JDBC实现类,通俗点讲,就是能够连接到数据库功能的东西就是驱动,由于市面上有很多数据库,Oracle.MySql等等,所以java就有一个连接数据库

Java基础学习笔记二十七 DBUtils和连接池

DBUtils 如果只使用JDBC进行开发,我们会发现冗余代码过多,为了简化JDBC开发,本案例我们讲采用apache commons组件一个成员:DBUtils.DBUtils就是JDBC的简化开发工具包.需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具. DBUtils是java编程中的数据库操作实用工具,小巧简单实用. DBUtils封装了对JDBC的操作,简化了JDBC操作,可以少写代码. Dbutils三个核心功能介绍 QueryRunner中

day18(JDBC事务&连接池介绍&DBUtils工具介绍&BaseServlet作用)

day18总结 今日思维导图: 今日内容 事务 连接池 ThreadLocal BaseServlet自定义Servlet父类(只要求会用,不要求会写) DBUtils à commons-dbutils ? 事务 ? 事务的四大特性:ACID: mysql中操作事务 jdbc中操作事务 ? ? ? 事务概述 为了方便演示事务,我们需要创建一个account表: CREATE TABLE account( ????id INT PRIMARY KEY AUTO_INCREMENT, ????NA

在jdbc基础上进阶一小步的C3p0 连接池(DBCP 不能读xml配置文件,已淘汰) 和DBUtils 中两个主要类QueryRunner和ResultSetHandler的使用

首先看C3p0这个连接池,最大优势可以自动读取默认的配置文件 <?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <default-config> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl&

网络协议 finally{ return问题 注入问题 jdbc注册驱动问题 PreparedStatement 连接池目的 1.2.1DBCP连接池 C3P0连接池 MYSQL两种方式进行实物管理 JDBC事务 DBUtils事务 ThreadLocal 事务特性 并发访问 隔离级别

1.1.1 API详解:注册驱动 DriverManager.registerDriver(new com.mysql.jdbc.Driver());不建议使用 原因有2个: >导致驱动被注册2次. >强烈依赖数据库的驱动jar 解决办法: Class.forName("com.mysql.jdbc.Driver"); 1.1.2 API详解:java.sql.Statement接口: 操作sql语句,并返回相应结果 String sql = "某SQL语句&qu

使用dbutils的PooledDB连接池,操作数据库

使用dbutils的PooledDB连接池,操作数据库. 这样就不需要每次执行sql后都关闭数据库连接,频繁的创建连接,消耗时间 如果是使用一个连接一直不关闭,多线程下运行一段时间后很容易出现OperationalError: (2006, ‘MySQL server has gone away’)这个错误. 使用PooledDB解决. # coding=utf-8 """ 使用DBUtils数据库连接池中的连接,操作数据库 OperationalError: (2006,

DBUtils和连接池

今日内容介绍1.DBUtils2.连接池 ###01DButils工具类的介绍个三个核心类 * A: DButils工具类的介绍个三个核心类 * a: 概述 * DBUtils是java编程中的数据库操作实用工具,小巧简单实用. * DBUtils封装了对JDBC的操作,简化了JDBC操作,可以少写代码. * DBUtils就是JDBC的简化开发工具包.需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具. * b: Dbutils三个核心功能介绍 * Qu

【转】【很全很新】C3P0 连接池和 DBUtils 配合事务使用总结

[转]https://blog.csdn.net/guozhaohui628/article/details/84793028 很久没用原生连接池,最近想写个小功能,结果发现很多地方不太懂,然后网上搜了半天的 c3p0 相关内容,全不符合我想要的.相同内容太多 而且没什么,所以我自己来总结下吧. 01 总结全文从以下来总结 连接池的作用,为什么要使用连接池书写自己的连接池,用于理解框架 c3p0 等连接池连接池框架 c3p0 使用连接池框架 c3p0 和 DBUtils 的配合使用配合事务的使用