我是 Vertx 的新手。我正在尝试在我的应用程序中创建 thymeleaf 模板引擎,但它会引发此错误
java:不兼容的类型:io.vertx.core.Vertx 无法转换为 io.vertx.reactivex.core.Vertx
如果我投到然后我vertx
得到io.vertx.reactive.core.Vertx
这个错误
java.lang.ClassCastException:io.vertx.core.impl.VertxImpl 不能转换为 io.vertx.reactivex.core.Vertx
除了那个数据库连接是成功的,如果我删除 TemplateEngine 行代码运行顺利。
package com.firstapp.main;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
import io.vertx.core.Promise;
import io.vertx.core.http.HttpServer;
import io.vertx.core.http.HttpServerResponse;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.RoutingContext;
import io.vertx.mysqlclient.MySQLConnectOptions;
import io.vertx.mysqlclient.MySQLPool;
import io.vertx.reactivex.core.Vertx;
import io.vertx.reactivex.ext.web.common.template.TemplateEngine;
import io.vertx.reactivex.ext.web.handler.TemplateHandler;
import io.vertx.reactivex.ext.web.templ.thymeleaf.ThymeleafTemplateEngine;
import io.vertx.sqlclient.PoolOptions;
import io.vertx.sqlclient.SqlConnection;
public class MainVerticle extends AbstractVerticle {
private int server_port = 8080;
@Override
public void start(Promise<Void> startPromise) throws Exception {
Future<Void> handshake = prepareDatabase().compose(estb -> startServer());
handshake.onComplete(startPromise);
}
private Future<Void> startServer(){
Promise<Void> promise = Promise.promise();
Router router = Router.router(vertx);
HttpServer server = vertx.createHttpServer();
TemplateEngine engine = ThymeleafTemplateEngine.create((Vertx) vertx);
TemplateHandler handler = TemplateHandler.create(engine);
router.route("/").handler(routingContext -> {
HttpServerResponse response = routingContext.response();
response.putHeader("content-type", "text/html").end("<h1>First App</h1>");
});
server.requestHandler(router).listen(config().getInteger("http.port", server_port), result -> {
if(result.succeeded()){
System.out.println("Server Started at Port '"+server_port+"'");
promise.complete();
}
else{
System.out.println("Failed to Start Server");
promise.fail(result.cause());
}
});
return promise.future();
}
private Future<Void> prepareDatabase(){
Promise<Void> promise = Promise.promise();
MySQLConnectOptions connectOptions = new MySQLConnectOptions()
.setPort(3306)
.setHost("localhost")
.setDatabase("vertx_db")
.setUser("root")
.setPassword("");
PoolOptions poolOptions = new PoolOptions().setMaxSize(5);
MySQLPool client = MySQLPool.pool(vertx, connectOptions, poolOptions);
client.getConnection(connect -> {
if (connect.failed()){
System.out.println("Failed to Connect to Database.");
promise.fail(connect.cause());
}
else{
SqlConnection conn = connect.result();
conn.close();
System.out.println("Database connection successful.");
promise.complete();
}
});
return promise.future();
}
}
如果您知道如何解决,请指导我。谢谢