当前位置： 代码网 > 服务器>服务器>云虚拟主机 > Docker部署XXL-JOB的示例代码

Docker部署XXL-JOB的示例代码

2024年11月03日 • 云虚拟主机 •我要评论
1. 引言xxl-job 是一个开源的分布式任务调度平台，旨在简化定时任务的管理和调度操作。其强大的功能和灵活性，使其在互联网公司和各大企业的定时任务管理中得到了广泛应用。本文将详细介绍如何在 mys

1. 引言

xxl-job 是一个开源的分布式任务调度平台，旨在简化定时任务的管理和调度操作。其强大的功能和灵活性，使其在互联网公司和各大企业的定时任务管理中得到了广泛应用。本文将详细介绍如何在 mysql 中创建一个专门的用户以支持 xxl-job，并使用 docker 容器化方式快速部署 xxl-job 的管理端。

2. 环境准备

在开始部署之前，确保你已经准备好以下环境：

  • mysql：用于存储 xxl-job 的调度任务和日志。
  • docker：用于容器化部署 xxl-job，确保其在不同环境中快速一致地运行。

此外，还需要确保 mysql 服务已经启动并能够接受远程连接。docker 的安装和基础操作应当已具备，以确保后续的部署工作顺利进行。

3. 创建 mysql 用户并授予权限

为了确保 xxl-job 在 mysql 中拥有足够的权限操作调度任务数据，我们需要创建一个独立的 mysql 用户并授予其适当的权限。

3.1 登录 mysql

首先，使用以下命令以 root 用户身份登录到 mysql：

mysql -u root -p

3.2 创建数据库

接着，创建一个专用于存储 xxl-job 数据的数据库：

create database if not exists `xxl_job` default character set utf8mb4 collate utf8mb4_unicode_ci;

此步骤确保数据库使用 utf-8 编码，以支持多语言环境下的数据存储。

在这里插入图片描述

3.3 创建用户并授予权限

为 xxl-job 创建一个专门的 mysql 用户，并授予其对 xxl_job 数据库的全部操作权限：

create user 'xxl_job'@'%' identified by 'your_password';
grant all privileges on xxl_job.* to 'xxl_job'@'%';
flush privileges;

在这里，我们使用通配符 % 允许来自任何主机的连接。如果安全性要求较高，可以将其限制为特定主机。

在这里插入图片描述

3.4 初始化 xxl-job 数据库

xxl-job 提供了一套初始化 sql 脚本，用于创建所需的数据表和初始数据。

use `xxl_job`;

set names utf8mb4;

create table `xxl_job_info` (
  `id` int(11) not null auto_increment,
  `job_group` int(11) not null comment '执行器主键id',
  `job_desc` varchar(255) not null,
  `add_time` datetime default null,
  `update_time` datetime default null,
  `author` varchar(64) default null comment '作者',
  `alarm_email` varchar(255) default null comment '报警邮件',
  `schedule_type` varchar(50) not null default 'none' comment '调度类型',
  `schedule_conf` varchar(128) default null comment '调度配置，值含义取决于调度类型',
  `misfire_strategy` varchar(50) not null default 'do_nothing' comment '调度过期策略',
  `executor_route_strategy` varchar(50) default null comment '执行器路由策略',
  `executor_handler` varchar(255) default null comment '执行器任务handler',
  `executor_param` varchar(512) default null comment '执行器任务参数',
  `executor_block_strategy` varchar(50) default null comment '阻塞处理策略',
  `executor_timeout` int(11) not null default '0' comment '任务执行超时时间，单位秒',
  `executor_fail_retry_count` int(11) not null default '0' comment '失败重试次数',
  `glue_type` varchar(50) not null comment 'glue类型',
  `glue_source` mediumtext comment 'glue源代码',
  `glue_remark` varchar(128) default null comment 'glue备注',
  `glue_updatetime` datetime default null comment 'glue更新时间',
  `child_jobid` varchar(255) default null comment '子任务id，多个逗号分隔',
  `trigger_status` tinyint(4) not null default '0' comment '调度状态：0-停止，1-运行',
  `trigger_last_time` bigint(13) not null default '0' comment '上次调度时间',
  `trigger_next_time` bigint(13) not null default '0' comment '下次调度时间',
  primary key (`id`)
) engine=innodb default charset=utf8mb4;

create table `xxl_job_log` (
  `id` bigint(20) not null auto_increment,
  `job_group` int(11) not null comment '执行器主键id',
  `job_id` int(11) not null comment '任务，主键id',
  `executor_address` varchar(255) default null comment '执行器地址，本次执行的地址',
  `executor_handler` varchar(255) default null comment '执行器任务handler',
  `executor_param` varchar(512) default null comment '执行器任务参数',
  `executor_sharding_param` varchar(20) default null comment '执行器任务分片参数，格式如 1/2',
  `executor_fail_retry_count` int(11) not null default '0' comment '失败重试次数',
  `trigger_time` datetime default null comment '调度-时间',
  `trigger_code` int(11) not null comment '调度-结果',
  `trigger_msg` text comment '调度-日志',
  `handle_time` datetime default null comment '执行-时间',
  `handle_code` int(11) not null comment '执行-状态',
  `handle_msg` text comment '执行-日志',
  `alarm_status` tinyint(4) not null default '0' comment '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败',
  primary key (`id`),
  key `i_trigger_time` (`trigger_time`),
  key `i_handle_code` (`handle_code`)
) engine=innodb default charset=utf8mb4;

create table `xxl_job_log_report` (
  `id` int(11) not null auto_increment,
  `trigger_day` datetime default null comment '调度-时间',
  `running_count` int(11) not null default '0' comment '运行中-日志数量',
  `suc_count` int(11) not null default '0' comment '执行成功-日志数量',
  `fail_count` int(11) not null default '0' comment '执行失败-日志数量',
  `update_time` datetime default null,
  primary key (`id`),
  unique key `i_trigger_day` (`trigger_day`) using btree
) engine=innodb default charset=utf8mb4;

create table `xxl_job_logglue` (
  `id` int(11) not null auto_increment,
  `job_id` int(11) not null comment '任务，主键id',
  `glue_type` varchar(50) default null comment 'glue类型',
  `glue_source` mediumtext comment 'glue源代码',
  `glue_remark` varchar(128) not null comment 'glue备注',
  `add_time` datetime default null,
  `update_time` datetime default null,
  primary key (`id`)
) engine=innodb default charset=utf8mb4;

create table `xxl_job_registry` (
  `id` int(11) not null auto_increment,
  `registry_group` varchar(50) not null,
  `registry_key` varchar(255) not null,
  `registry_value` varchar(255) not null,
  `update_time` datetime default null,
  primary key (`id`),
  key `i_g_k_v` (`registry_group`,`registry_key`,`registry_value`)
) engine=innodb default charset=utf8mb4;

create table `xxl_job_group` (
  `id` int(11) not null auto_increment,
  `app_name` varchar(64) not null comment '执行器appname',
  `title` varchar(12) not null comment '执行器名称',
  `address_type` tinyint(4) not null default '0' comment '执行器地址类型：0=自动注册、1=手动录入',
  `address_list` text comment '执行器地址列表，多地址逗号分隔',
  `update_time` datetime default null,
  primary key (`id`)
) engine=innodb default charset=utf8mb4;

create table `xxl_job_user` (
  `id` int(11) not null auto_increment,
  `username` varchar(50) not null comment '账号',
  `password` varchar(50) not null comment '密码',
  `role` tinyint(4) not null comment '角色：0-普通用户、1-管理员',
  `permission` varchar(255) default null comment '权限：执行器id列表，多个逗号分割',
  primary key (`id`),
  unique key `i_username` (`username`) using btree
) engine=innodb default charset=utf8mb4;

create table `xxl_job_lock` (
  `lock_name` varchar(50) not null comment '锁名称',
  primary key (`lock_name`)
) engine=innodb default charset=utf8mb4;

insert into `xxl_job_group`(`id`, `app_name`, `title`, `address_type`, `address_list`, `update_time`) values (1, 'xxl-job-executor-sample', '示例执行器', 0, null, '2018-11-03 22:21:31' );
insert into `xxl_job_info`(`id`, `job_group`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `schedule_type`, `schedule_conf`, `misfire_strategy`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) values (1, 1, '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'xxl', '', 'cron', '0 0 0 * * ? *', 'do_nothing', 'first', 'demojobhandler', '', 'serial_execution', 0, 0, 'bean', '', 'glue代码初始化', '2018-11-03 22:21:31', '');
insert into `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) values (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, null);
insert into `xxl_job_lock` ( `lock_name`) values ( 'schedule_lock');

commit;

执行完这些 sql 语句后，xxl-job 将拥有必要的数据结构来存储任务信息和执行日志。

在这里插入图片描述

4. 使用 docker 部署 xxl-job

xxl-job 支持 docker 容器化部署，使其可以快速在任何支持 docker 的环境中运行。以下是详细的部署步骤：

4.1 拉取 xxl-job 镜像

首先，从 docker hub 拉取最新版本的 xxl-job 管理端镜像：

docker pull xuxueli/xxl-job-admin:2.4.1

确保使用的是最新版镜像，以获得最新功能和安全更新。

4.2 运行 xxl-job 容器

使用以下命令运行 xxl-job 容器：

mkdir -p /usr/local/docker/xxl-job/logs

docker run --restart=always --privileged=true -e params="--spring.datasource.username=xxl_job --spring.datasource.password=your_password --spring.datasource.url=jdbc:mysql://your_mysql_host:3306/xxl_job?useunicode=true&characterencoding=utf-8&autoreconnect=true&servertimezone=asia/shanghai" -p 8080:8080 -v /usr/local/docker/xxl-job/logs:/data/applogs --name xxl-job-admin -d xuxueli/xxl-job-admin:2.4.1

这里，我们使用了多种参数来确保 xxl-job 能够正确连接到 mysql 数据库，并且配置了日志存储路径。

在这里插入图片描述

参数解析

  • --restart=always：确保容器在崩溃后自动重启。
  • --privileged=true：为容器赋予更多权限，避免某些受限操作失败。
  • -e params：通过环境变量传递 spring boot 配置项，确保数据库连接参数正确无误。
  • -p 8080:8080：将容器内部的 8080 端口映射到主机，以便外部访问。
  • -v /usr/local/docker/xxl-job/logs:/data/applogs：将主机的日志目录挂载到容器，方便日志持久化和分析。

4.3 常见问题与调试

在运行过程中，可能会遇到 mysql 连接失败或端口冲突等问题。你可以通过以下步骤进行排查：

  • 确认 mysql 服务正常运行，并且 docker 容器可以访问 mysql 服务器。
  • 检查 docker logs xxl-job-admin 输出，分析日志以排除配置错误或环境问题。

5. 配置 xxl-job

当容器成功运行后，你可以通过浏览器访问 http://your_server_ip:8080/xxl-job-admin 进行管理后台的配置。首次登录时，使用默认的用户名和密码：admin/123456。

5.1 修改默认密码

出于安全考虑，建议立即修改默认密码。登录后进入用户管理页面，更新管理员账户的密码，避免因弱密码带来的安全风险。

5.2 配置调度中心

在 调度中心配置 页面中，设置集群信息和调度策略。你可以根据业务需求配置不同的执行策略，如并行执行、错峰执行等，以满足复杂场景下的任务调度需求。

6. 验证部署

配置完成后，你可以创建一个简单的任务来验证 xxl-job 是否正常工作。以下是一个快速的验证步骤：

  • 进入 xxl-job 管理后台。
  • 新建一个调度任务，例如每分钟执行一次的 hello world 打印任务。
  • 观察任务执行情况，确保任务按预期时间和频率执行。

如果任务执行成功，说明 xxl-job 已经正确部署并可以投入生产使用。

在这里插入图片描述

7. 总结

通过本文的介绍，我们完成了在 docker 环境中部署 xxl-job 的全过程。从 mysql 数据库用户的创建，到 docker 容器的部署，再到最后的任务验证，xxl-job 的部署步骤清晰明确。借助 docker，xxl-job 可以快速部署到任何支持 docker 的环境中，极大简化了运维工作。

到此这篇关于docker部署xxl-job的示例代码的文章就介绍到这了,更多相关docker部署xxl-job内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！

赞 (0)

相关文章:

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

发表评论

验证码：
最近更新的文章
推荐阅读
大家感兴趣的文章
Copyright © 2017-2025  代码网 保留所有权利. 粤ICP备2024248653号
站长QQ:2386932994 | 联系邮箱：2386932994@qq.com