package com.xkyii.spry.web.service;  
  
import com.xkyii.spry.web.entity.SysLoginInfo;  
import com.xkyii.spry.web.entity.SysUser;  
import com.xkyii.spry.web.repository.SysLoginInfoRepository;  
import io.quarkus.hibernate.reactive.panache.Panache;  
import io.quarkus.hibernate.reactive.panache.common.WithTransaction;  
import io.smallrye.mutiny.Uni;  
import io.vertx.core.Vertx;  
import jakarta.enterprise.context.ApplicationScoped;  
import jakarta.inject.Inject;  
import org.jboss.logging.Logger;  
  
import java.util.Date;  
  
@ApplicationScoped  
public class SysLoginInfoService {  
  
    @Inject  
    Logger logger;  
  
    @Inject  
    SysLoginInfoRepository loginInfoRepository;  
  
    public Uni<SysLoginInfo> create(SysUser user) {  
  
        SysLoginInfo info = new SysLoginInfo();  
        info.setUserName(user.getUserName());  
        info.setIpaddr("127.0.0.1");  
        info.setLoginLocation("内网IP");  
        info.setBrowser("Chrome 11");  
        info.setOs("Unknown");  
        info.setStatus("1");  
        info.setMsg("成功");  
        info.setLoginTime(new Date());  
  
        logger.info("创建登录日志");  
  
        return loginInfoRepository.persist(info);  
    }  
}

import java.util.concurrent.Executor;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.ScheduledExecutorService;
  
@ApplicationScoped  
public class SysUserService {
    
    @Inject  
    Executor executor;  
      
    @Inject  
    ExecutorService executorService;  
      
    @Inject  
    ScheduledExecutorService scheduledExecutorService;
      
    @WithTransaction  
    public Uni<LoginOutput> login(LoginCommand input) {
      
        String username = input.getUsername();  
        return userRepository.find("userName", username).firstResult()
            // 省略其他步骤
            // ...
            // 保存登录日志 (想要个异步效果)  
            .onItem().invoke(u -> {
            
                // java.lang.IllegalStateException: HR000069: Detected use of the reactive Session from a different Thread than the one which was used to open the reactive Session - this suggests an invalid integration; original thread [245]: 'vert.x-eventloop-thread-3' current Thread [2456]: 'executor-thread-1'  
                executor.execute(() -> {  
                    loginInfoService.create(u)  
                        .subscribe().with(x -> logger.info("创建登录日志 with executor"), Throwable::printStackTrace);  
                });

                // java.lang.IllegalStateException: HR000069: Detected use of the reactive Session from a different Thread than the one which was used to open the reactive Session - this suggests an invalid integration; original thread [244]: 'vert.x-eventloop-thread-2' current Thread [2589]: 'executor-thread-1'  
                executorService.execute(() -> {  
                    loginInfoService.create(u)  
                        .subscribe().with(x -> logger.info("创建登录日志 with executorService"), Throwable::printStackTrace);  
                });
        
                // java.lang.IllegalStateException: HR000068: This method should exclusively be invoked from a Vert.x EventLoop thread; currently running on thread 'executor-thread-1'  
                scheduledExecutorService.schedule(() -> {  
                    loginInfoService.create(u)  
                        .subscribe().with(x -> logger.info("创建登录日志 with scheduledExecutorService"), Throwable::printStackTrace);  
                }, 10, TimeUnit.MILLISECONDS);
            }
            // 生成token  
            .onItem().transform(u -> new LoginOutput(tokenService.generateToken(u)))  
            ;
    }
}

@ApplicationScoped  
public class SysUserService {
      
    @WithTransaction  
    public Uni<LoginOutput> login(LoginCommand input) {
      
        String username = input.getUsername();  
        return userRepository.find("userName", username).firstResult()
            // 省略其他步骤
            // ...
            // 保存登录日志 (想要个异步效果)  
            .onItem().invoke(u -> {
                
                // 1
                // 运行在同一个线程,没报错,但是也没有保存成功。
                Vertx.currentContext().runOnContext(e -> {  
                        loginInfoService.create(u)  
                            .subscribe().with(x -> logger.info("创建登录日志 with Vertx.currentContext()"), Throwable::printStackTrace);  
                });
    
                // 2
                // java.lang.IllegalStateException: HR000069: Detected use of the reactive Session from a different Thread than the one which was used to open the reactive Session - this suggests an invalid integration; original thread [245]: 'vert.x-eventloop-thread-3' current Thread [1056]: 'vert.x-worker-thread-2'  
                vertx.executeBlocking(e -> {  
                    loginInfoService.create(u)  
                        .emitOn(Infrastructure.getDefaultWorkerPool())  
                        .subscribe().with(x -> logger.info("创建登录日志 with vertx.executeBlocking"), Throwable::printStackTrace);  
                });
            }
            // 生成token  
            .onItem().transform(u -> new LoginOutput(tokenService.generateToken(u)))  
            ;
    }
}

@ApplicationScoped  
public class SysUserService {
      
    @WithTransaction  
    public Uni<LoginOutput> login(LoginCommand input) {
      
        String username = input.getUsername();  
        return userRepository.find("userName", username).firstResult()
            // 省略其他步骤
            // ...
            // 保存登录日志 (想要个异步效果)  
            .onItem().invoke(u -> {
    
                // 1 
                // 保存成功,但是实际上没有达到异步效果,只是subscribe在另一个线程而已  
                loginInfoService.create(u)  
                    .emitOn(Infrastructure.getDefaultWorkerPool())  
                    .subscribe().with(x -> logger.info("创建登录日志 emitOn Infrastructure.getDefaultWorkerPool()"), Throwable::printStackTrace);  
                
                // 2
                // java.lang.IllegalStateException: HR000069: Detected use of the reactive Session from a different Thread than the one which was used to open the reactive Session - this suggests an invalid integration; original thread [244]: 'vert.x-eventloop-thread-2' current Thread [1911]: 'executor-thread-1'  
                loginInfoService.create(u)  
                    .runSubscriptionOn(Infrastructure.getDefaultWorkerPool())  
                    .subscribe().with(x -> logger.info("创建登录日志 runSubscriptionOn Infrastructure.getDefaultWorkerPool()"), Throwable::printStackTrace);
            }
            // 生成token  
            .onItem().transform(u -> new LoginOutput(tokenService.generateToken(u)))  
            ;
    }
}

  
import io.vertx.core.Vertx;  
import io.vertx.core.impl.ContextInternal;  
import io.vertx.core.impl.EventLoopContext;  
import io.vertx.core.impl.VertxInternal;

import static io.quarkus.vertx.core.runtime.context.VertxContextSafetyToggle.setContextSafe;

@ApplicationScoped  
public class SysUserService {
      
    @WithTransaction  
    public Uni<LoginOutput> login(LoginCommand input) {
      
        String username = input.getUsername();  
        return userRepository.find("userName", username).firstResult()
            // 省略其他步骤
            // ...
            // 保存登录日志 (想要个异步效果)  
            .onItem().invoke(u -> {
        
                // 既然只能运行在EventLoop thread,而当前eventloop thread又达不到异步效果,就尝试在别的eventloop thread上运行
                VertxInternal vxi = (VertxInternal) vertx;  
                Executor delegate = vertx.nettyEventLoopGroup();  
                EventLoopContext context = vxi.createEventLoopContext();  
                ContextInternal internal = (ContextInternal) VertxContext.getOrCreateDuplicatedContext(context);  
                setContextSafe(internal, true);  
                delegate.execute(() -> internal.dispatch(() -> {  
                    loginInfoService.create(u)
                        .subscribe().with(x -> logger.info("创建登录日志 with getOrCreateDuplicatedContext"), Throwable::printStackTrace); 
                }));
            }
            // 生成token  
            .onItem().transform(u -> new LoginOutput(tokenService.generateToken(u)))  
            ;
    }
}

package com.xkyii.spry.web.service;  
  
import com.xkyii.spry.web.entity.SysLoginInfo;  
import com.xkyii.spry.web.entity.SysUser;  
import com.xkyii.spry.web.repository.SysLoginInfoRepository;  
import io.quarkus.hibernate.reactive.panache.common.WithTransaction;  
import io.quarkus.vertx.ConsumeEvent;  
import io.smallrye.mutiny.Uni;  
import jakarta.enterprise.context.ApplicationScoped;  
import jakarta.inject.Inject;  
import org.jboss.logging.Logger;  
  
import java.util.Date;  
  
@ApplicationScoped  
public class SysLoginInfoService {  
  
    @Inject  
    Logger logger;  
  
    @Inject  
    SysLoginInfoRepository loginInfoRepository;  
  
    @ConsumeEvent("SysLoginInfoService-create-with-SysUser")  
    @WithTransaction  
    public Uni<SysLoginInfo> create(SysUser user) {  
  
        SysLoginInfo info = new SysLoginInfo();  
        // info.setInfoId(180L);  
        info.setUserName(user.getUserName());  
        info.setIpaddr("127.0.0.1");  
        info.setLoginLocation("内网IP");  
        info.setBrowser("Chrome 11");  
        info.setOs("Unknown");  
        info.setStatus("1");  
        info.setMsg("成功");  
        info.setLoginTime(new Date());  
  
  
        logger.info("创建登录日志");  
  
        return loginInfoRepository.persist(info);  
    }  
}

  
import io.vertx.core.Vertx;  

@ApplicationScoped  
public class SysUserService {
    @Inject  
    Vertx vertx;
      
    @WithTransaction  
    public Uni<LoginOutput> login(LoginCommand input) {
        
        String username = input.getUsername();  
        return userRepository.find("userName", username).firstResult()
            // 省略其他步骤
            // ...
            // 保存登录日志 (想要个异步效果)  
            .onItem().invoke(u -> {
                vertx.eventBus().publish("SysLoginInfoService-create-with-SysUser", u);
            }
            // 生成token  
            .onItem().transform(u -> new LoginOutput(tokenService.generateToken(u)))  
            ;
    }
}

@Path("/demo")  
@Consumes(MediaType.APPLICATION_JSON)  
@Produces(MediaType.APPLICATION_JSON)  
public class DemoResource {  
  
    @GET  
    @Operation(summary = "Get Demo")  
    public Response get(@Length(min=2, max=20) String name) {  
        return Response.ok(JsonObject.of("name", name)).build();  
    }  
}

// KsMessageInterpolator 
//  -> ResourceBundleMessageInterpolator
//  -> AbstractMessageInterpolator
//  -> MessageInterpolator
public class KsMessageInterpolator extends ResourceBundleMessageInterpolator {  
    public KsMessageInterpolator() {  
        super(new PlatformResourceBundleLocator("i18n/validation"));  
    }  
}

@Recorder  
public class KsServerRecorder {  
  
    public Supplier<MessageInterpolator> messageInterpolatorSupplier() {  
        return () -> new ResourceBundleMessageInterpolator(  
            new PlatformResourceBundleLocator("i18n/validation"));  
    }  
}

@BuildStep  
@Record(ExecutionTime.STATIC_INIT)  
SyntheticBeanBuildItem registerMessageInterpolator(KsServerRecorder ksServerRecorder) {  
    return SyntheticBeanBuildItem.configure(MessageInterpolator.class)  
        .scope(Singleton.class)  
        .supplier(ksServerRecorder.messageInterpolatorSupplier())  
        .done();  
}