使用MySQL UDFs来调用gearman分布式任务分发系统

使用MySQL UDFs来调用gearman分布式任务分发系统

当向表插入数据的时候,触发执行某些任务 安装gearman参加:
http://www.ttlsa.com/html/663.html 一.安装gearman-mysql-udf # apt-get install libmysql++-dev # wget
https://launchpad.net/gearman-mysql-udf/trunk/0.6/+download/gearman-mysql-udf-0.6.tar.gz # tar zxvf gearman-mysql-udf-0.6.tar.gz # ./configure  –with-mysql=/usr/bin/mysql_config –libdir=/usr/lib/mysql/plugin # make # make install # mysql [codesyntax lang=”sql”] mysql> CREATE FUNCTION gman_do RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_do_high RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_do_low RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_do_background RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_do_high_background RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_do_low_background RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> CREATE AGGREGATE FUNCTION gman_sum RETURNS INTEGER SONAME “libgearman_mysql_udf.so”; mysql> CREATE FUNCTION gman_servers_set RETURNS STRING SONAME “libgearman_mysql_udf.so”; mysql> SELECT gman_servers_set(“192.168.1.60:4730,192.168.1.60:4731″) as gman_servers;  //设置gearman server +————————————-+ | gman_servers                        | +————————————-+ | 192.168.1.60:4730,192.168.1.60:4731 | +————————————-+ mysql> create table udf_test( -> id int unsigned auto_increment primary key, -> val varchar(20) not null);  //新建表 mysql> create trigger sendmail before insert on udf_test for each row set @return=gman_do_background(‘MAIL’,’undef’);  //创建触发器,当向表udf_test插入数据时候,执行任务。 [/codesyntax] # perl -MCPAN -e shell cpan> install Gearman::Worker  //安装Gearman::Worker模块 cpan> install Mail::SendEasy   //安装Mail::SendEasy模块 # vi WORKER_SENDMAIL.pl   //创建worker任务 [codesyntax lang=”perl”] use strict; use Mail::SendEasy ; use v5.10; use Gearman::Worker; my $worker=new Gearman::Worker; $worker->job_servers(‘192.168.1.60:4730’); $worker->register_function(MAIL=>\&sendmail); $worker->work while 1; sub sendmail{ my $job=shift; my $date=localtime; my $mail = new Mail::SendEasy( smtp => ‘smtp.ttlsa.com’ , user =>
‘service@ttlsa.com’ , pass => ‘******’, ); print “$date\n”; my $status = $mail->send( from    =>
‘service@ttlsa.com’ , from_title => ‘ttlsa’ , to      =>
‘xxxxx@qq.com’ , subject => “MAIL Test $date” , msg     => “$date” , html    => “<b>test $date</b>” , ); if (!$status) { print $mail->error ;} } [/codesyntax] # perl WORKER_SENDMAIL.pl & # perl WORKER_SENDMAIL.pl &  //在后台运行两个worker 二.测试 1.向udf_test表插入数据 mysql> insert into udf_test value (”,’a’); 2.查看是否收到邮件
使用MySQL UDFs来调用gearman分布式任务分发系统 三.Gearman server信息 # telnet 192.168.1.60 4730 Trying 192.168.1.60… Connected to 192.168.1.60. Escape character is ‘^]’. status MAIL    0       0       2 说明:第一列worker名称;第二列jobs执行数量;第三列jobs队列数量;第四列可用worker数量

转载于:https://my.oschina.net/766/blog/211040

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

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

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

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

(0)


相关推荐

  • java文件上传总结[通俗易懂]

    java文件上传总结[通俗易懂]前言文件上传是各类应用中经常碰到的需求,不管是上传图片、文件、音频、视频等,或者其他类型的文件,都是后端需要解决的,采用什么样的方式进行上传,或者对上传后的文件如何进行存储,甚至如何更加高效的上传文件等问题,都是在实际开发中需要解决的,本文将对常用的文件上传使用进行一下简单的小结以springboot为例,下面我们就开始撸码吧,开工前我们还是做一下简单的准备吧,本文的演示demo框架为springboot2.2.1版本,只需简单引入一个下面的依赖即可,其他需要用到的,我们增量添加即可 <de

  • keras卷积层_keras实现全卷积神经网络

    keras卷积层_keras实现全卷积神经网络分组卷积在pytorch中比较容易实现,只需要在卷积的时候设置group参数即可比如设置分组数为2conv_group=nn.Conv2d(C_in,C_out,kernel_size=3,stride=3,padding=1,groups=2)但是,tensorflow中目前还没有分组卷积,只能自己手动编写分组卷积函数。在编写程序之前大家要先理解分组卷积的形式,也就是对特征图在通道上进行划分,例如设置group=3,对输入特征图通道划分成三组,输出特征图也要划分成3组,再对三组输入输出特

    2022年10月30日
  • Spring Cloud入门操作手册(Hoxton)

    Spring Cloud入门操作手册(Hoxton)文章目录@[toc]springcloud介绍springcloud技术组成SpringCloud对比Dubbo一、service-服务二、commons通用项目新建maven项目pom.xmljava源文件pojoItemUserOrderserviceItemServiceUserServiceOrderServiceutilCookieUtilJsonUtilJso…

  • 深入Java事务的原理与应用

    一、什么是JAVA事务通常的观念认为,事务仅与数据库相关。事务必须服从ISO/IEC所制定的ACID原则。ACID是原子性(atomicity)、一致性(consistency)、隔离性(iso

    2021年12月26日
  • 单点登录原理与简单实现(单点登录原理)

    GitHub:https://github.com/sheefee/simple-sso一、单系统登录机制1、http无状态协议  web应用采用browser/server架构,http作为通信协议。http是无状态协议,浏览器的每一次请求,服务器会独立处理,不与之前或之后的请求产生关联,这个过程用下图说明,三次请求/响应对之间没有任何联系  但这也同时意味着,任何用户都能通…

  • linux 启动nginx[通俗易懂]

    linux 启动nginx[通俗易懂]启动操作nginx-c/usr/local/nginx/conf/nginx.conf-c参数指定了要加载的nginx配置文件路径停止操作停止操作是通过向nginx进程发送信号来进行的步骤1:查询nginx主进程号ps-ef|grepnginx在进程列表里 面找master进程,它的编号就是主进程号了。步骤2:发送信号从容停止Nginx…

发表回复

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

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