-
Notifications
You must be signed in to change notification settings - Fork 2.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
2 changed files
with
330 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,329 @@ | ||
//// | ||
This guide is maintained in the main Quarkus repository | ||
and pull requests should be submitted there: | ||
https://github.com/quarkusio/quarkus/tree/master/docs/src/main/asciidoc | ||
//// | ||
= Quarkus - Scheduling Periodic Clustered Tasks | ||
|
||
include::./attributes.adoc[] | ||
|
||
Modern applications often need to run specific tasks periodically. | ||
In this guide, you learn how to schedule periodic clustered tasks using the http://www.quartz-scheduler.org/[Quartz extension]. | ||
|
||
[NOTE] | ||
==== | ||
This extension is considered `preview`. | ||
API or configuration properties might change as the extension matures. | ||
Feedback is welcome on our https://groups.google.com/d/forum/quarkus-dev[mailing list] or as issues in our https://github.com/quarkusio/quarkus/issues[GitHub issue tracker]. | ||
==== | ||
|
||
== Prerequisites | ||
|
||
To complete this guide, you need: | ||
|
||
* less than 10 minutes | ||
* an IDE | ||
* JDK 1.8+ installed with `JAVA_HOME` configured appropriately | ||
* Apache Maven 3.5.3+ | ||
* Docker and docker compose installed on your machine | ||
|
||
== Architecture | ||
|
||
In this guide, we create a straightforward application accessible using HTTP to get the current list of all created tasks by schedulers running on two instances of the same application. | ||
A task is created every 10 seconds. | ||
|
||
== Solution | ||
|
||
We recommend that you follow the instructions in the next sections and create the application step by step. | ||
However, you can go right to the completed example. | ||
|
||
Clone the Git repository: `git clone {quickstarts-clone-url}`, or download an {quickstarts-archive-url}[archive]. | ||
|
||
The solution is located in the `quartz-quickstart` {quickstarts-tree-url}/quartz-quickstart[directory]. | ||
|
||
== Creating the Maven project | ||
|
||
First, we need a new project. Create a new project with the following command: | ||
|
||
[source,shell,subs=attributes+] | ||
---- | ||
mvn io.quarkus:quarkus-maven-plugin:{quarkus-version}:create \ | ||
-DprojectGroupId=org.acme \ | ||
-DprojectArtifactId=quartz-quickstart \ | ||
-DclassName="org.acme.quartz.TaskResource" \ | ||
-Dpath="/tasks" \ | ||
-Dextensions="quartz, hibernate-orm-panache, flyway, resteasy-jsonb, jdbc-postgresql" | ||
cd quartz-quickstart | ||
---- | ||
|
||
It generates: | ||
|
||
* the Maven structure | ||
* a landing page accessible on `http://localhost:8080` | ||
* example `Dockerfile` files for both `native` and `jvm` modes | ||
* the application configuration file | ||
* an `org.acme.quartz.TaskResource` resource | ||
* an associated test | ||
|
||
The Maven project also imports the Quarkus quartz extension. | ||
|
||
== Creating the Task Entity | ||
|
||
In the `org.acme.quartz` package, create the `Task` class, with the following content: | ||
|
||
[source,java] | ||
---- | ||
package org.acme.quartz; | ||
import javax.persistence.Entity; | ||
import java.time.Instant; | ||
import javax.persistence.Table; | ||
import io.quarkus.hibernate.orm.panache.PanacheEntity; | ||
@Entity | ||
@Table(name="TASKS") | ||
public class Task extends PanacheEntity { <1> | ||
public Instant createdAt; | ||
public Task() { | ||
createdAt = Instant.now(); | ||
} | ||
public Task(Instant time) { | ||
this.createdAt = time; | ||
} | ||
} | ||
---- | ||
1. Declare the entity using https://quarkus.io/guides/hibernate-orm-panache[Panache] | ||
|
||
== Creating a scheduled job | ||
|
||
In the `org.acme.quartz` package, create the `TaskBean` class, with the following content: | ||
|
||
[source,java] | ||
---- | ||
package org.acme.quartz; | ||
import javax.enterprise.context.ApplicationScoped; | ||
import javax.transaction.Transactional; | ||
import io.quarkus.scheduler.Scheduled; | ||
@ApplicationScoped <1> | ||
public class TaskBean { | ||
@Transactional | ||
@Scheduled(every = "10s") <2> | ||
void schedule() { | ||
Task task = new Task(execution.getFireTime()); <3> | ||
task.persist(); <4> | ||
} | ||
} | ||
---- | ||
1. Declare the bean in the _application_ scope | ||
2. Use the `@Scheduled` annotation to instruct Quarkus to run this method every 10 seconds. | ||
3. The create a new `Task` with the current start time. | ||
4. Persist the task in database using https://quarkus.io/guides/hibernate-orm-panache[Panache]. | ||
|
||
== Updating the application configuration file | ||
|
||
Edit the `application.properties` file and add the below configuration: | ||
[source,shell] | ||
---- | ||
# Quartz configuration | ||
quarkus.quartz.clustered=true <1> | ||
quarkus.quartz.store-type=db <2> | ||
# Datasource configuration. | ||
quarkus.datasource.url=jdbc:postgresql://localhost/quarkus_test | ||
quarkus.datasource.driver=org.postgresql.Driver | ||
quarkus.datasource.username=quarkus_test | ||
quarkus.datasource.password=quarkus_test | ||
# Hibernate configuration | ||
quarkus.hibernate-orm.database.generation=none | ||
quarkus.hibernate-orm.log.sql=true | ||
quarkus.hibernate-orm.sql-load-script=no-file | ||
# flyway configuration | ||
quarkus.flyway.connect-retries=10 | ||
quarkus.flyway.table=flyway_quarkus_history | ||
quarkus.flyway.migrate-at-start=true | ||
quarkus.flyway.baseline-on-migrate=true | ||
quarkus.flyway.baseline-version=1.0 | ||
quarkus.flyway.baseline-description=Quartz | ||
---- | ||
|
||
1. Indicate that the scheduler will be run in clustered mode | ||
2. Use the database store to persists job related information so that they can be shared between nodes | ||
|
||
== Updating the resource and the test | ||
|
||
Edit the `TaskResource` class, and update the content to: | ||
|
||
[source,java] | ||
---- | ||
package org.acme.quartz; | ||
import java.util.List; | ||
import javax.ws.rs.GET; | ||
import javax.ws.rs.Path; | ||
import javax.ws.rs.Produces; | ||
import javax.ws.rs.core.MediaType; | ||
@Path("/tasks") | ||
@Produces(MediaType.APPLICATION_JSON) | ||
public class TaskResource { | ||
@GET | ||
public List<Task> listAll() { | ||
return Task.listAll(); <1> | ||
} | ||
} | ||
---- | ||
1. Retrieve the list of created tasks from database | ||
|
||
We also need to update the tests. Edit the `TaskResourceTest` class to match: | ||
|
||
[source, java] | ||
---- | ||
package org.acme.quartz; | ||
import io.quarkus.test.junit.QuarkusTest; | ||
import org.junit.jupiter.api.Test; | ||
import static io.restassured.RestAssured.given; | ||
import static org.hamcrest.CoreMatchers.is; | ||
@QuarkusTest | ||
public class TaskResourceTest { | ||
@Test | ||
public void tasks() throws InterruptedException { | ||
Thread.sleep(1000); // wait at least a seconds to have the first task created | ||
given() | ||
.when().get("/tasks") | ||
.then() | ||
.statusCode(200) | ||
.body("size()", is(1)); | ||
} | ||
} | ||
---- | ||
1. Ensure that we have a `200` response and at least one task created | ||
|
||
== Creating Quartz Tables | ||
Add a SQL migration file named `src/main/resources/db/migration/V2.0.0__QuarkusQuartzTasks.sql` with the content copied from | ||
file with the content from this {quickstarts-blob-url}/quartz-quickstart/src/main/resources/db/migration/V2.0.0__QuarkusQuartzTasks.sql[Quartz Tasks migrationfile]. | ||
|
||
== Configuring the load balancer | ||
|
||
In the root directory, create a `nginx.conf` file with the following content | ||
[source,shell] | ||
---- | ||
user nginx; | ||
events { | ||
worker_connections 1000; | ||
} | ||
http { | ||
server { | ||
listen 8080; | ||
location / { | ||
proxy_pass http://tasks:8080; <1> | ||
} | ||
} | ||
} | ||
---- | ||
|
||
1. Route all traffic to our tasks application | ||
|
||
== Setting Application Deployment | ||
|
||
In the root directory, create a `docker-compose.yml` file with the following content | ||
[source,shell] | ||
---- | ||
version: '3' | ||
services: | ||
tasks: <1> | ||
image: quarkus-quickstarts/quartz:1.0 | ||
build: | ||
context: ./ | ||
dockerfile: src/main/docker/Dockerfile.${QUARKUS_MODE:-jvm} | ||
environment: | ||
QUARKUS_DATASOURCE_URL: jdbc:postgresql://postgres/quarkus_test | ||
networks: | ||
- tasks-network | ||
depends_on: | ||
- postgres | ||
nginx: <2> | ||
image: nginx:1.17.6 | ||
volumes: | ||
- ./nginx.conf:/etc/nginx/nginx.conf:ro | ||
depends_on: | ||
- tasks | ||
ports: | ||
- 8080:8080 | ||
networks: | ||
- tasks-network | ||
postgres: <3> | ||
image: postgres:11.3 | ||
container_name: quarkus_test | ||
environment: | ||
- POSTGRES_USER=quarkus_test | ||
- POSTGRES_PASSWORD=quarkus_test | ||
- POSTGRES_DB=quarkus_test | ||
ports: | ||
- 5432:5432 | ||
networks: | ||
- tasks-network | ||
networks: | ||
tasks-network: | ||
driver: bridge | ||
---- | ||
|
||
1. Define the tasks service | ||
2. Define an nginx load balancer to route incoming traffic to an appropriate node | ||
3. Define the configuration to run database | ||
|
||
== Running the database | ||
|
||
In a separate terminal, run the below command | ||
[source,shell] | ||
---- | ||
docker-compose up postgres <1> | ||
---- | ||
1. Start the database instance using the configuration options supplied in the `docker-compose.yml` file | ||
|
||
== Run the application in Dev Mode | ||
|
||
Run the application with: `./mvnw quarkus:dev`. | ||
After a few seconds, open another terminal and run `curl localhost:8080/tasks` to verify that we have task created. | ||
|
||
As usual, the application can be packaged using `./mvnw clean package` and executed using the `-runner.jar` file. | ||
You can also generate the native executable with `./mvnw clean package -Pnative`. | ||
|
||
== Packaging the application and run several instances | ||
The application can be packaged using `./mvnw clean package`. Once the build is successfully, run the below command | ||
[source,shell] | ||
---- | ||
docker-compose up --scale tasks=2 --scale nginx=1 <1> | ||
---- | ||
1. Start two instances of the application and a load balancer | ||
|
||
After a few seconds, in another terminal, run `curl localhost:8080/tasks` to verify that tasks were only created at different instants and in an interval of 10 seconds. | ||
|
||
You can also generate the native executable with `./mvnw clean package -Pnative`. | ||
|
||
[[quartz-configuration-reference]] | ||
== Quartz Configuration Reference | ||
|
||
include::{generated-dir}/config/quarkus-quartz.adoc[leveloffset=+1, opts=optional] |