В вашем classpath:
vertx.yml
zero:
lime: mongo
vertx:
instance:
- name: vx-zero
options:
maxEventLoopExecuteTime: 30000000000
vertx-mongo.yml
mongo: # Ключ должен быть mongo, не может быть заменён.
db_name: vertx_zero_up
port: 27017
host: 127.0.0.1
Здесь игнорируется код отправителя, mongo db поддерживается только в классе потребителя стандартным способом. Также часть lime является случайной, например: После того как вы установите код следующим образом:
lime: mongo-db
Вы должны установить имя файла up.god.file в пути к ресурсам как vertx-mongo-db.yml
, после чего вы сможете настроить конфигурацию mongo db в этом файле.
vertx-inject.yml
mongo: io.vertx.mod.plugin.mongo.MongoInfix
import io.vertx.core.eventbus.Message;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.mongo.MongoClient;
import io.vertx.up.annotations.Address;
import io.vertx.up.annotations.Queue;
import jakarta.inject.infix.Mongo;
import io.vertx.up.commune.Envelop;
import io.vertx.up.util.Jackson;
@Queue
public class UserWorker {
@Mongo
private transient MongoClient client;
@Address("ZERO://ROLE")
public void async(final Message<Envelop> message) {
final User user = Envelop.data(message, User.class);
final JsonObject userData = new JsonObject(Jackson.serialize(user));
this.client.save("DB_USER", userData, res -> {
if (res.succeeded()) {
message.reply(Envelop.success("Hello World"));
} else {
res.cause().printStackTrace();
}
});
}
}
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )