在 Micronaut 应用程序中使用 Spring 个 Bean
Use Spring Beans In Micronaut Applications
我一直在找这样的东西。
拥有这个 micronaut 应用代码
@Configuration
@SpringBootApplication(exclude = {org.springframework.boot.autoconfigure.cassandra.CassandraAutoConfiguration.class,
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration.class,
org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration.class,
org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration.class})
@ComponentScan(basePackageClasses = HelloController.class)
public class Application {
public static void main(String[] args) throws Exception {
System.setProperty("akka.config", "/Users/nb38tv/workspace/hello-micronaut/src/main/resources/config/");
System.setProperty("akka.config.file", "application.conf");
ConfigurableApplicationContext springContext = ReactiveConnectorBootable.loadReactiveConnector();
ConfigurableApplicationContext context = new MicronautApplicationContext();
context.setParent(springContext);
context.start();
Micronaut.run(Application.class);
}
}
如何将 Spring 的 ApplicationContext 与 Micronaut 的应用程序上下文合并。
我需要它,因为我有一个使用 Spring 的 ApplicationContext 来注入一些 bean 的库。
然后在我的控制器中我需要使用它。
@Controller("/hello")
public class HelloController {
@Inject
private ReactorConnectorManager<RequestInfoDTO, String> reactorConnectorRestManagerExecutor;
@Get(produces = MediaType.TEXT_PLAIN)
public String index() {
if(reactorConnectorRestManagerExecutor == null){
return "boooo";
}
return "Hello World";
}
}
其中 ReactorConnectorManager
是在 Spring context
中加载的 bean
此致
你可以查看 this there is an example how to integrate Micronaut with Spring
我已经基于 this 上面的代码创建了一个简单的应用程序。
例如,在 http://localhost:8080/hello/World
上 returns:Hello World with Test : World and Test : World
。所以看起来 Controller
使用 Bean
.
package greeting.example;
import io.micronaut.runtime.Micronaut;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import java.util.function.Function;
@SpringBootApplication
public class Application {
public static void main(String... args) {
Micronaut.run(Application.class);
}
@Bean
Function<String, String> stringService(){
return (value) -> "Test : "+ value;
}
}
和
package greeting.example;
import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import io.reactivex.Single;
import javax.inject.Inject;
import java.util.function.Function;
@Controller("/")
public class HelloController {
@Inject
Function<String, String> stringService;
@Autowired
private ApplicationContext applicationContext;
@Get(uri = "/hello/{name}", produces = MediaType.TEXT_PLAIN)
public Single<String> hello(String name) {
Function<String, String> service = applicationContext.getBean(Function.class);
return Single.just("Hello " + name + " with " + stringService.apply(name)
+ " and " + service.apply(name));
}
}
更新
允许访问 ConfigurableApplicationContext context
的黑客攻击。在 Application
中创建类似单例的东西,或者在我的示例静态字段中创建你的 context
:
static ConfigurableApplicationContext springContext;
...
ConfigurableApplicationContext springContext = ReactiveConnectorBootable.loadReactiveConnector();
然后在你的 HelloController
:
@Get(produces = MediaType.TEXT_PLAIN)
public String index() {
ReactorConnectorManager<RequestInfoDTO, String> reactorConnectorRestManagerExecutor =
Application.springContext.getBean(ReactorConnectorManager<RequestInfoDTO, String>.class);
if(reactorConnectorRestManagerExecutor == null){
return "boooo";
}
return "Hello World";
}
我一直在找这样的东西。
拥有这个 micronaut 应用代码
@Configuration
@SpringBootApplication(exclude = {org.springframework.boot.autoconfigure.cassandra.CassandraAutoConfiguration.class,
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration.class,
org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration.class,
org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration.class})
@ComponentScan(basePackageClasses = HelloController.class)
public class Application {
public static void main(String[] args) throws Exception {
System.setProperty("akka.config", "/Users/nb38tv/workspace/hello-micronaut/src/main/resources/config/");
System.setProperty("akka.config.file", "application.conf");
ConfigurableApplicationContext springContext = ReactiveConnectorBootable.loadReactiveConnector();
ConfigurableApplicationContext context = new MicronautApplicationContext();
context.setParent(springContext);
context.start();
Micronaut.run(Application.class);
}
}
如何将 Spring 的 ApplicationContext 与 Micronaut 的应用程序上下文合并。
我需要它,因为我有一个使用 Spring 的 ApplicationContext 来注入一些 bean 的库。
然后在我的控制器中我需要使用它。
@Controller("/hello")
public class HelloController {
@Inject
private ReactorConnectorManager<RequestInfoDTO, String> reactorConnectorRestManagerExecutor;
@Get(produces = MediaType.TEXT_PLAIN)
public String index() {
if(reactorConnectorRestManagerExecutor == null){
return "boooo";
}
return "Hello World";
}
}
其中 ReactorConnectorManager
是在 Spring context
此致
你可以查看 this there is an example how to integrate Micronaut with Spring
我已经基于 this 上面的代码创建了一个简单的应用程序。
例如,在 http://localhost:8080/hello/World
上 returns:Hello World with Test : World and Test : World
。所以看起来 Controller
使用 Bean
.
package greeting.example;
import io.micronaut.runtime.Micronaut;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import java.util.function.Function;
@SpringBootApplication
public class Application {
public static void main(String... args) {
Micronaut.run(Application.class);
}
@Bean
Function<String, String> stringService(){
return (value) -> "Test : "+ value;
}
}
和
package greeting.example;
import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import io.reactivex.Single;
import javax.inject.Inject;
import java.util.function.Function;
@Controller("/")
public class HelloController {
@Inject
Function<String, String> stringService;
@Autowired
private ApplicationContext applicationContext;
@Get(uri = "/hello/{name}", produces = MediaType.TEXT_PLAIN)
public Single<String> hello(String name) {
Function<String, String> service = applicationContext.getBean(Function.class);
return Single.just("Hello " + name + " with " + stringService.apply(name)
+ " and " + service.apply(name));
}
}
更新
允许访问 ConfigurableApplicationContext context
的黑客攻击。在 Application
中创建类似单例的东西,或者在我的示例静态字段中创建你的 context
:
static ConfigurableApplicationContext springContext;
...
ConfigurableApplicationContext springContext = ReactiveConnectorBootable.loadReactiveConnector();
然后在你的 HelloController
:
@Get(produces = MediaType.TEXT_PLAIN)
public String index() {
ReactorConnectorManager<RequestInfoDTO, String> reactorConnectorRestManagerExecutor =
Application.springContext.getBean(ReactorConnectorManager<RequestInfoDTO, String>.class);
if(reactorConnectorRestManagerExecutor == null){
return "boooo";
}
return "Hello World";
}