java websocket框架_websocket监听数据库

java websocket框架_websocket监听数据库HandlerSocket简介HandlerSocket是针对Mysql的一个NoSQL插件,它作为一个守护进程工作在mysqld进程里面,接收tcp连接,并处理来自客户端的请求。HandlerSocket不支持SQL查询,作为替代,它支持表的简单的CRUD操作。由于下面的原因,在某些情况下HandlerSocket比mysqld/libmysql对儿更快速:-HandlerSocket处理数据…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

HandlerSocket简介

HandlerSocket是针对Mysql的一个NoSQL插件,它作为一个守护进程工作在mysqld进程里面,接收tcp连接,并处理来自客户端的请求。HandlerSocket不支持SQL查询,作为替代,它支持表的简单的CRUD操作。

由于下面的原因,在某些情况下HandlerSocket比mysqld/libmysql对儿更快速:

-HandlerSocket 处理数据不需要解析SQL,由于这个原因使得其占用少量CPU资源。

-HandlerSocket 从客户端批量读取多个请求并处理他们,这使得其占用更少的CPU和磁盘使用率。

-HandlerSocket 客户端/服务器协议比mysql/libmysql对儿更简洁,这使得其占用更少的网络使用率。

Mysql版本需要5.1及以上,mysql的安装就不写了

一、服务器端安装、配置、及测试

1、下载

[root@vm3 ~]# git clone http://github.com/DeNADev/HandlerSocket-Plugin-for-MySQL.git或

[root@vm3 ~]# wget -O HandlerSocket-Plugin-for-MySQL.zip –no-check-certificate https://github.com/DeNADev/HandlerSocket-Plugin-for-MySQL/archive/master.zip2、安装

[root@vm3 ~]# cd HandlerSocket-Plugin-for-MySQL-master/

[root@vm3 HandlerSocket-Plugin-for-MySQL-master]# ./autogen.sh

[root@vm3 HandlerSocket-Plugin-for-MySQL-master]# ./configure –with-mysql-source=../mysql-5.1.62 –with-mysql-bindir=/usr/local/mysql/bin –with-mysql-plugindir=/usr/local/mysql/lib/mysql/plugin/

[root@vm3 HandlerSocket-Plugin-for-MySQL-master]# make

[root@vm3 HandlerSocket-Plugin-for-MySQL-master]# make install

3、配置

以root身份登录到mysql,用下面命令安装handlersocket插件

mysql> install plugin handlersocket soname ‘handlersocket.so’;

Query OK, 0 rows affected (0.00 sec)

mysql> show plugins;

| handlersocket | ACTIVE | DAEMON | handlersocket.so | BSD |编辑my.cnf文件,在[mysqld]段下加入下列配置项

loose_handlersocket_port    = 9998

loose_handlersocket_port_wr    = 9999

loose_handlersocket_threads    = 4

loose_handlersocket_threads_wr  = 1

loose_handlersocket_address    = 192.168.18.240重启mysql服务

[root@vm3 ~]# service mysqld restart

4、验证部署

查看handlersocket线程

mysql> show processlist;

|3| system user|connecting host|NULL|Connect|NULL|handlersocket:mode=rd,0 conns,0 active|NULL|

|4| system user|connecting host|NULL|Connect|NULL|handlersocket:mode=rd,0 conns,0 active|NULL|

|5| system user|connecting host|NULL|Connect|NULL|handlersocket:mode=rd,0 conns,0 active|NULL|

|6| system user|connecting host|handlersocket|Connect|NULL|handlersocket:mode=wr,0 conns,0 active|NULL|

|7| system user|connecting host|NULL|Connect|NULL|handlersocket:mode=rd,0 conns,0 active|NULL|查看监听端口

[root@vm3 ~]# netstat -ntupl

Active Internet connections (only servers)

Proto Recv-Q Send-Q Local AddressForeign AddressStatePID/Program name

tcp000.0.0.0:33060.0.0.0:*LISTEN 5522/mysqld

tcp00192.168.18.240:99980.0.0.0:*LISTEN 5522/mysqld

tcp00192.168.18.240:99990.0.0.0:*LISTEN 5522/mysqld

至此服务器端部署完毕,下面部署客户端,客户端使用PHP程序语言

二、客户端安装、配置、测试

1、下载

[root@vm4 ~]# wget    http://php-handlersocket.googlecode.com/files/php-handlersocket-0.2.0.tar.gz

这里使用的不是最新的0.3.1版本,而是老的0.2.0,版本,新版本安装时报错,如有兄弟成功安装,请告知,3ks

2、安装

[root@vm4 ~]# tar zxvf php-handlersocket-0.2.0.tar.gz

[root@vm4 ~]# cd php-handlersocket/

[root@vm4 php-handlersocket]# phpize

[root@vm4 php-handlersocket]# ./configure –with-php-config=/usr/bin/php-config

[root@vm4 php-handlersocket]# make

[root@vm4 php-handlersocket]# make install

3、配置

本例使用的是rpm安装的php,编辑/etc/php.ini,添加或修改如下行

extension_dir = “/usr/lib64/php/modules”

extension=handlersocket.so

4、验证

重启httpd服务

[root@vm4 handlersocket]# service httpd restart编写phpinfo.php

[root@vm4 html]# vim /var/www/html/phpinfo.php

phpinfo();访问页面,看看是否加载了handlersocket扩展

141609614.png

ok,扩展已经启用了

5、测试

使用下面代码测试

$host = ‘192.168.18.240’;

$port = 9998;

$port_wr = 9999;

$dbname = ‘hstestdb’;

$table = ‘hstesttbl’;

//GET

$hs = new HandlerSocket($host, $port);

if (!($hs->openIndex(1, $dbname, $table, HandlerSocket::PRIMARY, ‘k,v’)))

{

echo $hs->getError(), PHP_EOL;

die();

}

$retval = $hs->executeSingle(1, ‘=’, array(‘k1’), 1, 0);

var_dump($retval);

$retval = $hs->executeMulti(

array(array(1, ‘=’, array(‘k1’), 1, 0),

array(1, ‘=’, array(‘k2’), 1, 0)));

var_dump($retval);

unset($hs);

//UPDATE

$hs = new HandlerSocket($host, $port_wr);

if (!($hs->openIndex(2, $dbname, $table, ”, ‘v’)))

{

echo $hs->getError(), PHP_EOL;

die();

}

if ($hs->executeUpdate(2, ‘=’, array(‘k1’), array(‘V1’), 1, 0) === false)

{

echo $hs->getError(), PHP_EOL;

die();

}

unset($hs);

//INSERT

$hs = new HandlerSocket($host, $port_wr);

if (!($hs->openIndex(3, $dbname, $table, ”, ‘k,v’)))

{

echo $hs->getError(), PHP_EOL;

die();

}

if ($hs->executeInsert(3, array(‘k2’, ‘v2’)) === false)

{

echo $hs->getError(), PHP_EOL;

}

if ($hs->executeInsert(3, array(‘k3’, ‘v3’)) === false)

{

echo ‘A’, $hs->getError(), PHP_EOL;

}

if ($hs->executeInsert(3, array(‘k4’, ‘v4’)) === false)

{

echo ‘B’, $hs->getError(), PHP_EOL;

}

unset($hs);

//DELETE

$hs = new HandlerSocket($host, $port_wr);

if (!($hs->openIndex(4, $dbname, $table, ”, ”)))

{

echo $hs->getError(), PHP_EOL;

die();

}

if ($hs->executeDelete(4, ‘=’, array(‘k2’)) === false)

{

echo $hs->getError(), PHP_EOL;

die();

}至此客户端也部署完毕了,性能和具体应用有待测试!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/172629.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 检索com类工厂中的组件失败_检索com类工厂的组件失败

    检索com类工厂中的组件失败_检索com类工厂的组件失败出现以下错误:检索COM类工厂中CLSID为{000209FF-0000-0000-C000-000000000046}的组件失败,原因是出现以下错误:8000401a因为配置标识不正确,系统无法开始服务器进程。请检查用户名和密码。(异常来自HRESULT:0x8000401A)。解决方案:1.开始-dcomcnfg,启动组件服务。2.找到Micro

  • 45天带你玩转Node(第二天)走进Node.js「建议收藏」

    45天带你玩转Node(第二天)走进Node.js「建议收藏」粉丝要求博主系统的写一篇关于Node.js的学习资料,但其实我们的Node.js知识点并不少,所以博主为大家搭建了一个专栏,为了方便大家系统的学习Node.js,大家记得订阅哦!虽然我们的Node.js还很年轻,但是他也已经有了很高的地位,让我们尽情的畅游在Node.js的专栏中吧,希望通过此专栏我们能够系统的将Node.js学好,它将会成为我们的一大亮点,我们可以用这款前端中的后端语言让提升我们的价值与眼界,如今的他也已经成为面试官口中的高并发面试内容了,一起加油!

  • Scrapy常用命令建议收藏

    scrapy全局命令要想了解在scrapy中由哪些全局命令,可以在不进入scrapy爬虫项目目录的情况下运行scrapy-h(1)fetch命令fetch命令主要用来显示爬虫爬取的过程,如果

    2021年12月19日
  • Java web 实战项目案例

    Java web 实战项目案例Javaweb实战项目,采用MVC的设计模式,jdbc编程,由Javaweb+Servlet+mysql实现简单的增删改查,模糊查询,导出excel表格数据等。以下是Javaweb项目详情案例Javaweb+mysql+servlet+eclipse实现Javaweb商城管理系统https://blog.csdn.net/liqz666/article/detail…

  • 基于springboot的旅游管理系统

    基于springboot的旅游管理系统1,项目功能:(1)旅游路线(2)旅游景点(3)餐饮住宿(4)旅游车票(5)旅游保险(6)旅游攻略(7)注意事项(8)会员中心(9)用户管理(10)内容管理(11)业务管理(12)数据分析2,涉及技术:SpringBoot框架,Maven,Tomcat3,开发环境:IDEA,MySQL数据库4,讲解方式:从环境安装,项目搭建,以及项目介绍等进行讲解5,包含资料:项目源码(含数据库文件),环境安装包,项目文档。课程链接+项目下载:基于spr…

  • 安装maven步骤_织梦安装教程

    安装maven步骤_织梦安装教程熟练的配置开发环境是每一个程序员必备的功课,俗话说:工欲善其事,必先利其器。本文须知:安装maven环境之前要先安装javajdk环境(没有安装java环境的可以先去看安装JAVA环境的教程)Maven3.3+requireJDK1.7及以上。第一步:下载maven(本教程安装的是3.8.4)官方下载链接:https://maven.apache.org/download.cgiBinary是可执行版本,已经编译好可以直接使用。Source是源代码版本,需要自己编译成可执..

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号