CREATE SEQUENCE "xxl_job_group_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; SELECT setval('"xxl_job_group_id_seq"', 2, true); CREATE SEQUENCE "xxl_job_info_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; SELECT setval('"xxl_job_info_id_seq"', 8, true); CREATE SEQUENCE "xxl_job_log_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; CREATE SEQUENCE "xxl_job_logglue_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; CREATE SEQUENCE "xxl_job_log_report_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; CREATE SEQUENCE "xxl_job_registry_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; CREATE SEQUENCE "xxl_job_user_id_seq" INCREMENT 1 MINVALUE 1 MAXVALUE 2147483647 START 1 CACHE 1; SELECT setval('"xxl_job_user_id_seq"', 2, true); CREATE TABLE "xxl_job_group" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_group_id_seq'::regclass), "app_name" varchar(64) COLLATE "pg_catalog"."default" NOT NULL, "title" varchar(12) COLLATE "pg_catalog"."default" NOT NULL, "address_type" int2 NOT NULL, "address_list" text COLLATE "pg_catalog"."default", "update_time" timestamp(6) ) ; COMMENT ON COLUMN "xxl_job_group"."app_name" IS '执行器AppName'; COMMENT ON COLUMN "xxl_job_group"."title" IS '执行器名称'; COMMENT ON COLUMN "xxl_job_group"."address_type" IS '执行器地址类型：0=自动注册、1=手动录入'; COMMENT ON COLUMN "xxl_job_group"."address_list" IS '执行器地址列表，多地址逗号分隔'; CREATE TABLE "xxl_job_info" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_info_id_seq'::regclass), "job_group" int4 NOT NULL, "job_desc" varchar(255) COLLATE "pg_catalog"."default" NOT NULL, "add_time" timestamp(6), "update_time" timestamp(6), "author" varchar(64) COLLATE "pg_catalog"."default", "alarm_email" varchar(255) COLLATE "pg_catalog"."default", "schedule_type" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "schedule_conf" varchar(128) COLLATE "pg_catalog"."default", "misfire_strategy" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "executor_route_strategy" varchar(50) COLLATE "pg_catalog"."default", "executor_handler" varchar(255) COLLATE "pg_catalog"."default", "executor_param" varchar(512) COLLATE "pg_catalog"."default", "executor_block_strategy" varchar(50) COLLATE "pg_catalog"."default", "executor_timeout" int4 NOT NULL, "executor_fail_retry_count" int4 NOT NULL, "glue_type" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "glue_source" text COLLATE "pg_catalog"."default", "glue_remark" varchar(128) COLLATE "pg_catalog"."default", "glue_updatetime" timestamp(6), "child_jobid" varchar(255) COLLATE "pg_catalog"."default", "trigger_status" int2 NOT NULL, "trigger_last_time" int8 NOT NULL, "trigger_next_time" int8 NOT NULL ) ; COMMENT ON COLUMN "xxl_job_info"."job_group" IS '执行器主键ID'; COMMENT ON COLUMN "xxl_job_info"."author" IS '作者'; COMMENT ON COLUMN "xxl_job_info"."alarm_email" IS '报警邮件'; COMMENT ON COLUMN "xxl_job_info"."schedule_type" IS '调度类型'; COMMENT ON COLUMN "xxl_job_info"."schedule_conf" IS '调度配置，值含义取决于调度类型'; COMMENT ON COLUMN "xxl_job_info"."misfire_strategy" IS '调度过期策略'; COMMENT ON COLUMN "xxl_job_info"."executor_route_strategy" IS '执行器路由策略'; COMMENT ON COLUMN "xxl_job_info"."executor_handler" IS '执行器任务handler'; COMMENT ON COLUMN "xxl_job_info"."executor_param" IS '执行器任务参数'; COMMENT ON COLUMN "xxl_job_info"."executor_block_strategy" IS '阻塞处理策略'; COMMENT ON COLUMN "xxl_job_info"."executor_timeout" IS '任务执行超时时间，单位秒'; COMMENT ON COLUMN "xxl_job_info"."executor_fail_retry_count" IS '失败重试次数'; COMMENT ON COLUMN "xxl_job_info"."glue_type" IS 'GLUE类型'; COMMENT ON COLUMN "xxl_job_info"."glue_source" IS 'GLUE源代码'; COMMENT ON COLUMN "xxl_job_info"."glue_remark" IS 'GLUE备注'; COMMENT ON COLUMN "xxl_job_info"."glue_updatetime" IS 'GLUE更新时间'; COMMENT ON COLUMN "xxl_job_info"."child_jobid" IS '子任务ID，多个逗号分隔'; COMMENT ON COLUMN "xxl_job_info"."trigger_status" IS '调度状态：0-停止，1-运行'; COMMENT ON COLUMN "xxl_job_info"."trigger_last_time" IS '上次调度时间'; COMMENT ON COLUMN "xxl_job_info"."trigger_next_time" IS '下次调度时间'; CREATE TABLE "xxl_job_lock" ( "lock_name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL ) ; COMMENT ON COLUMN "xxl_job_lock"."lock_name" IS '锁名称'; CREATE TABLE "xxl_job_log" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_log_id_seq'::regclass), "job_group" int4 NOT NULL, "job_id" int4 NOT NULL, "executor_address" varchar(255) COLLATE "pg_catalog"."default", "executor_handler" varchar(255) COLLATE "pg_catalog"."default", "executor_param" varchar(512) COLLATE "pg_catalog"."default", "executor_sharding_param" varchar(20) COLLATE "pg_catalog"."default", "executor_fail_retry_count" int4 NOT NULL DEFAULT 0, "trigger_time" timestamp(6), "trigger_code" int4 NOT NULL, "trigger_msg" text COLLATE "pg_catalog"."default", "handle_time" timestamp(6), "handle_code" int4 NOT NULL, "handle_msg" text COLLATE "pg_catalog"."default", "alarm_status" int2 NOT NULL DEFAULT 0 ) ; COMMENT ON COLUMN "xxl_job_log"."job_group" IS '执行器主键ID'; COMMENT ON COLUMN "xxl_job_log"."job_id" IS '任务，主键ID'; COMMENT ON COLUMN "xxl_job_log"."executor_address" IS '执行器地址，本次执行的地址'; COMMENT ON COLUMN "xxl_job_log"."executor_handler" IS '执行器任务handler'; COMMENT ON COLUMN "xxl_job_log"."executor_param" IS '执行器任务参数'; COMMENT ON COLUMN "xxl_job_log"."executor_sharding_param" IS '执行器任务分片参数，格式如 1/2'; COMMENT ON COLUMN "xxl_job_log"."executor_fail_retry_count" IS '失败重试次数'; COMMENT ON COLUMN "xxl_job_log"."trigger_time" IS '调度-时间'; COMMENT ON COLUMN "xxl_job_log"."trigger_code" IS '调度-结果'; COMMENT ON COLUMN "xxl_job_log"."trigger_msg" IS '调度-日志'; COMMENT ON COLUMN "xxl_job_log"."handle_time" IS '执行-时间'; COMMENT ON COLUMN "xxl_job_log"."handle_code" IS '执行-状态'; COMMENT ON COLUMN "xxl_job_log"."handle_msg" IS '执行-日志'; COMMENT ON COLUMN "xxl_job_log"."alarm_status" IS '告警状态：0-默认、1-无需告警、2-告警成功、3-告警失败'; CREATE TABLE "xxl_job_log_report" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_log_report_id_seq'::regclass), "trigger_day" timestamp(6), "running_count" int4 NOT NULL, "suc_count" int4 NOT NULL, "fail_count" int4 NOT NULL, "update_time" timestamp(6) ) ; COMMENT ON COLUMN "xxl_job_log_report"."trigger_day" IS '调度-时间'; COMMENT ON COLUMN "xxl_job_log_report"."running_count" IS '运行中-日志数量'; COMMENT ON COLUMN "xxl_job_log_report"."suc_count" IS '执行成功-日志数量'; COMMENT ON COLUMN "xxl_job_log_report"."fail_count" IS '执行失败-日志数量'; CREATE TABLE "xxl_job_logglue" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_logglue_id_seq'::regclass), "job_id" int4 NOT NULL, "glue_type" varchar(50) COLLATE "pg_catalog"."default", "glue_source" text COLLATE "pg_catalog"."default", "glue_remark" varchar(128) COLLATE "pg_catalog"."default" NOT NULL, "add_time" timestamp(6), "update_time" timestamp(6) ) ; COMMENT ON COLUMN "xxl_job_logglue"."job_id" IS '任务，主键ID'; COMMENT ON COLUMN "xxl_job_logglue"."glue_type" IS 'GLUE类型'; COMMENT ON COLUMN "xxl_job_logglue"."glue_source" IS 'GLUE源代码'; COMMENT ON COLUMN "xxl_job_logglue"."glue_remark" IS 'GLUE备注'; CREATE TABLE "xxl_job_registry" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_registry_id_seq'::regclass), "registry_group" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "registry_key" varchar(255) COLLATE "pg_catalog"."default" NOT NULL, "registry_value" varchar(255) COLLATE "pg_catalog"."default" NOT NULL, "update_time" timestamp(6) ) ; CREATE TABLE "xxl_job_user" ( "id" int4 NOT NULL DEFAULT nextval('xxl_job_user_id_seq'::regclass), "username" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "password" varchar(50) COLLATE "pg_catalog"."default" NOT NULL, "role" int2 NOT NULL, "permission" varchar(255) COLLATE "pg_catalog"."default" ) ; COMMENT ON COLUMN "xxl_job_user"."username" IS '账号'; COMMENT ON COLUMN "xxl_job_user"."password" IS '密码'; COMMENT ON COLUMN "xxl_job_user"."role" IS '角色：0-普通用户、1-管理员'; COMMENT ON COLUMN "xxl_job_user"."permission" IS '权限：执行器ID列表，多个逗号分割'; ALTER TABLE "xxl_job_group" ADD CONSTRAINT "xxl_job_group_pkey" PRIMARY KEY ("id"); ALTER TABLE "xxl_job_info" ADD CONSTRAINT "xxl_job_info_pkey" PRIMARY KEY ("id"); ALTER TABLE "xxl_job_lock" ADD CONSTRAINT "xxl_job_lock_pkey" PRIMARY KEY ("lock_name"); CREATE INDEX "I_handle_code" ON "xxl_job_log" USING btree ( "handle_code" "pg_catalog"."int4_ops" ASC NULLS LAST ); CREATE INDEX "I_trigger_time" ON "xxl_job_log" USING btree ( "trigger_time" "pg_catalog"."timestamp_ops" ASC NULLS LAST ); ALTER TABLE "xxl_job_log" ADD CONSTRAINT "xxl_job_log_pkey" PRIMARY KEY ("id"); CREATE INDEX "i_trigger_day" ON "xxl_job_log_report" USING btree ( "trigger_day" "pg_catalog"."timestamp_ops" ASC NULLS LAST ); ALTER TABLE "xxl_job_log_report" ADD CONSTRAINT "xxl_job_log_report_pkey" PRIMARY KEY ("id"); ALTER TABLE "xxl_job_logglue" ADD CONSTRAINT "xxl_job_logglue_pkey" PRIMARY KEY ("id"); CREATE INDEX "i_g_k_v" ON "xxl_job_registry" USING btree ( "registry_group" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST, "registry_key" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST, "registry_value" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST ); ALTER TABLE "xxl_job_registry" ADD CONSTRAINT "xxl_job_registry_pkey" PRIMARY KEY ("id"); CREATE INDEX "i_username" ON "xxl_job_user" USING btree ( "username" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST ); ALTER TABLE "xxl_job_user" ADD CONSTRAINT "xxl_job_user_pkey" PRIMARY KEY ("id"); INSERT INTO "xxl_job_user" ("id", "username", "password", "role", "permission") VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL); INSERT INTO "xxl_job_group" ("id", "app_name", "title", "address_type", "address_list", "update_time") VALUES (1, 'xxl-job-executor', '执行器-测试组', 0, NULL, '2022-06-05 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (1, 1, 'java_script', '2022-06-07 01:48:38.21', '2022-06-07 01:57:43.739', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_GROOVY', 'package com.xxl.job.service.handler; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.IJobHandler; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLConnection; import java.util.Arrays; import java.util.concurrent.TimeUnit; public class HttpJobHandler extends IJobHandler { public static String sendGet(String url, String param) throws Exception{ String result = ""; String urlNameString = url + "?" + param; URL realUrl = new URL(urlNameString); // 打开和URL之间的连接 URLConnection connection = realUrl.openConnection(); // 设置通用的请求属性 connection.setRequestProperty("accept", "*/*"); connection.setRequestProperty("connection", "Keep-Alive"); connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); // 建立实际的连接 connection.setRequestProperty("Accept-Charset", "utf-8"); connection.setRequestProperty("contentType", "utf-8"); connection.connect(); BufferedReader inbf = new BufferedReader(new InputStreamReader( connection.getInputStream(),"utf-8")); String line; while ((line = inbf.readLine()) != null) { result += line; } inbf.close(); return result; } @Override public void execute() throws Exception { XxlJobHelper.log("开始执行模拟请求！"); XxlJobHelper.log("接收到的参数：{}", XxlJobHelper.getJobParam()); // 分片参数 int shardIndex = XxlJobHelper.getShardIndex(); int shardTotal = XxlJobHelper.getShardTotal(); XxlJobHelper.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal); //获取调度器传递参数 String url = XxlJobHelper.getJobParam(); XxlJobHelper.log(sendGet(url,"")); XxlJobHelper.log("模拟请求执行完成"); } }', 'java_script', '2022-06-07 01:57:43.739', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (2, 1, 'php_script', '2022-06-07 01:49:08.833', '2022-06-07 02:02:08.743', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_PHP', ' ', 'php_script', '2022-06-07 02:02:08.743', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (3, 1, 'python_script', '2022-06-07 01:49:40.531', '2022-06-07 02:04:03.534', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_PYTHON', '#!/usr/bin/python # -*- coding: UTF-8 -*- import time import urllib.request import urllib.parse import sys import codecs sys.stdout = codecs.getwriter("utf-8")(sys.stdout.detach()) print("xxl-job: hello python") print("脚本位置：", sys.argv[0]) print("任务参数：", sys.argv[1]) print("分片序号：", sys.argv[2]) print("分片总数：", sys.argv[3]) def gethttp(http_url): print(http_url) response = urllib.request.urlopen(http_url) result=response.read() print(result) pass gethttp(sys.argv[1]) print ("Good bye!") exit(0) ', 'python_script', '2022-06-07 02:04:03.534', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (5, 1, 'spring_bean_simple', '2022-06-07 01:53:28.497', '2022-06-07 01:53:28.497', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', 'demoJobHandler', 'test', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2022-06-07 01:53:28.497', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (6, 1, 'spring_bean_broadcast', '2022-06-07 01:54:45.836', '2022-06-07 01:54:59.474', 'zhangsan', '', 'FIX_RATE', '5', 'DO_NOTHING', 'SHARDING_BROADCAST', 'shardingJobHandler', '2022-06-01', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2022-06-07 01:54:45.836', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (7, 1, 'shell_script', '2022-06-07 01:50:13.086', '2022-06-07 02:05:11.828', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_SHELL', '#!/bin/bash echo "xxl-job: hello shell" echo "脚本位置：$0" echo "任务参数：$1" echo "分片序号 = $2" echo "分片总数 = $3" echo "开始HTTP模拟请求" url=$1 result=$(curl ${url} -s) echo $result echo "Good bye!" exit 0 ', 'shell_script', '2022-06-07 02:05:11.828', '', 0, 0, 0); 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", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (8, 1, 'node_script', '2022-06-07 01:51:43.617', '2022-06-07 02:06:47.131', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_NODEJS', '#!/usr/bin/env node console.log("xxl-job: hello nodejs") var arguments = process.argv console.log("脚本位置: " + arguments[1]) console.log("任务参数: " + arguments[2]) console.log("分片序号: " + arguments[3]) console.log("分片总数: " + arguments[4]) let name="张三"; console.log(`我是${name}`); console.log("Good bye!") process.exit(0) ', 'node_script', '2022-06-07 02:06:34.115', '', 0, 0, 0); INSERT INTO "xxl_job_lock" ("lock_name") VALUES ('schedule_lock');