模拟反应式返回类型Mono<Void>
是一种在反应式编程中常见的类型。它表示一个不返回任何值的Mono流。在响应式编程中，Mono是一种表示0或1个元素的流，而Void表示没有值。因此，Mono<Void>表示一个只发出完成信号而不发出任何值的流。
这种类型在异步编程中非常有用，特别是在需要执行一些副作用操作而不需要返回结果的情况下。例如，在处理HTTP请求时，我们可能只关心请求是否成功完成，而不需要返回任何数据。
Mono<Void>的优势在于它可以与其他反应式操作符无缝地集成，例如flatMap、filter和merge等。它还可以与其他类型的Mono或Flux进行组合，以构建更复杂的反应式流水线。
应用场景：
- 异步操作：当需要执行异步操作并且不需要返回结果时，可以使用Mono<Void>。例如，向数据库插入数据或发送异步消息。
- Web开发：在处理HTTP请求时，可以使用Mono<Void>来表示请求的处理结果。例如，处理POST请求后返回一个空的响应。
推荐的腾讯云相关产品： 腾讯云提供了一系列适用于云计算的产品和服务，以下是一些相关的产品：
- 云函数（Serverless）：腾讯云云函数是一种无服务器计算服务，可以让您无需管理服务器即可运行代码。您可以使用云函数来处理异步任务，包括处理Mono<Void>类型的操作。
- 弹性容器实例（Elastic Container Instance）：腾讯云弹性容器实例是一种无需管理基础设施即可运行容器的服务。您可以使用弹性容器实例来运行处理Mono<Void>类型的容器化应用程序。
更多关于腾讯云产品的信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
如何访问Mono类型的RequestBody参数。Spring Boot Webflux reactive。 我想返回一个ResponseEntity，而不是Mono。 @RequestMapping(value = "/poststudentdata", method = RequestMethod.POST, headers={"content-type=application/json"})
public ResponseEntity<String> poststudentData(@Valid @RequestBody Mono<St
浏览 74提问于2019-04-01得票数 1
Mono<Void> my_function(final String reviewObject){
return Mono.fromCallable(
() -> {
ReviewDto reviewDto = new ReviewDto();
try {
objectMapper.updateValue(reviewDto, reviewObject);
} catch (JsonMappingE
浏览 124提问于2021-02-15得票数 1
回答已采纳
我是项目反应器和网络流量的新手，我想重写我当前的传统的，阻塞的安全过滤器为反应式的，即：
当前筛选器如下所示：
@Component
@Slf4j
public class WhitelistingFilter extends OncePerRequestFilter {
private static final String SECURITY_PROPERTIES = "security.properties";
private final Properties securityProperties = readConfigurationFile(SECURITY_
浏览 58提问于2021-12-01得票数 0
1回答
我想使用反应式编程将我的excel文件存储到数据库中。在非反应式中很容易做到，但我不能在反应式中做类似的事情，我应该写什么来将它存储到我的mongo数据库中？
我的控制器
@PostMapping(path = "/file",consumes = MediaType.MULTIPART_FORM_DATA_VALUE,
produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public HttpStatus file(@RequestPart("files") Mono<F
浏览 5提问于2021-11-01得票数 1
1回答
我有一个Mono对象，我在这个对象上订阅了doOnsuccess，在这个方法中，我再次将数据保存在DB中(使用ReactiveCouchbaseRepository的CouchBase)。在那之后，我没有得到任何关于Line1和line2的日志。
但是，如果我不保存这个对象，这是可以正常工作的，这意味着我可以获得第2行的日志。
Mono<User> result = context.getPayload(User.class);
result.doOnSuccess( user -> {
System.out.println("######
浏览 4提问于2018-09-01得票数 1
我在我的项目中使用web flux，并尝试使用JPA存储库执行简单的CRUD操作。然而，我无法在数据库中持久化该对象。在DB中，对象始终使用空值进行持久化。请帮帮忙。提前谢谢。 这是我的pojo： @Entity
@Table(name="tbl_student")
@Data
public class Student {
@Id
@GeneratedValue(strategy= GenerationType.SEQUENCE,generator = "student_seq")
@SequenceGenerator(name=&#
浏览 25提问于2020-12-01得票数 1
回答已采纳
1回答
我正在尝试用下面的代码创建lambda。这里我调用了一个API (API网关)，它反过来调用返回"Second Lambda"的第二个Lambda，但是，当我测试它时，它给出的输出不支持响应类型作为处理程序()中的返回类型？有没有办法不使用阻塞调用block()来返回实际值？
public class FirstLambda implements RequestHandler<Object, Mono<String>> {
public Mono<String> handleRequest(final Object input, f
浏览 3提问于2022-01-04得票数 0
回答已采纳
在Spring MVC框架中，当控制器返回接口类型时，spring的消息转换器可以将返回值转换为适当的消息(如JSON)。
例如，当我调用'vehicle‘api时，我可能会收到一条JSON消息。
@GetMapping("vehicle")
public Vehicle getVehicle() {
return new Car();
}
public interface Vehicle {
}
public class Car implements Vehicle {
privat
浏览 3提问于2019-04-16得票数 0
我在spring中有一个服务，它需要使用十种不同的方法来获取数据。 我想让这些方法并行执行一些DB操作，然后返回到父线程。但是父线程应该等待，直到所有的响应到来，然后返回一个响应。 在我目前的方法中，我使用反应式mono异步执行所有方法，但主线程并不等待subscriber方法完成。 下面是我订阅的两个方法 private Mono<BaseResponse> getProfileDetails(long profileId){
return new Mono<BaseResponse>() {
@Override
浏览 13提问于2020-01-09得票数 1
回答已采纳
我正在尝试将返回void的postgresql存储库deleteById方法调整为返回Mono<Void> 存储库是我自动生成的一个服务，我这样使用它 使用字符串id作为参数的repository.deleteById(id)
浏览 49提问于2020-08-18得票数 0
2回答
使用Spring Boot2，是否有可能以反应式风格(Mono、Flux和它们的运算符)编写代码，但保留JDBC线程池系统？
目标是在R2DBC驱动程序可以用于生产时切换到它们，而不需要更改控制器和服务层。
非常感谢!
Saveriu
浏览 0提问于2019-01-02得票数 0
1回答
我正在尝试理解WebFlux，但在with客户端调用方面遇到了一些问题。我没有看到这一行System.out.println("customerId =“+ customerId)；执行它似乎没有调用端点。但是如果我使用.subscribe(customer -> {})订阅webclient，那么我可以看到这一行System.out.println("customerId =“+ customerId)；在端点端工作。我不明白为什么我必须订阅Mono call，或者我必须这样做？谢谢 @GetMapping("/customer/{customerId}
浏览 11提问于2020-01-13得票数 0
我希望缓存一个WebClient调用的结果的Mono (只有在它成功的情况下)。
通过阅读项目reactor addons文档，我觉得并不适合，因为它也缓存了错误，这是我不想要的。
因此，我不使用CacheMono，而是执行以下操作：
Cache<MyRequestObject, Mono<MyResponseObject>> myCaffeineCache =
Caffeine.newBuilder()
.maximumSize(100)
.expireAfterWrite(Duration.ofSeconds
浏览 3提问于2018-10-13得票数 10
回答已采纳
我正在使用邮递员向我的Spring应用程序发送一个POST请求。请求有一个JSON主体，它看起来如下所示：
{
"documents": [
{
"id": "1",
"text": "Piece of text 1",
"lang": "en"
},
{
"id
浏览 5提问于2020-10-14得票数 4
1回答
我称之为反应式的两种方法。
Mono<OrderPublicDto> order = orderWebClient.getOrderById(orderID, bearerToken);
Mono<DriverDto> driver = order.flatMap(o -> vehicleWebClient.getDriverById(o.getDriverId(), bearerToken));
我需要这样做，以便如果truckID from order (OrderPublicDto) == null，则在第二个方法中返回DriverDto空。
我怎么才能
浏览 5提问于2022-11-19得票数 -1
2回答
我正在尝试评估来自两个不同服务的Mono类型的响应
data class Customer(
val customerId : String ,
val customerBlance : CustomerBalance,
val customername : String ,
val customerRefNo : String
)
data class CustomerBalance(
val totalAmount : Double ,
val totalCreditAmount : Dou
浏览 23提问于2021-02-17得票数 0
1回答
我想实现WebFlux示例客户端，它可以使用http参数发出请求，并获得响应体和http响应代码。我试过这个： public ClientResponse execute(NotificationMessage nm)
Mono<String> transactionMono = Mono.just(convertedString);
return client.post().uri(builder -> builder.build())
.header(HttpHeaders.USER_AGENT, "agent&#
浏览 23提问于2019-06-21得票数 1
2回答
如何模拟返回Mono<Void>的方法
我有一个返回Mono<Void>的方法
public Mono<Void> deleteMethod(Post post) {
return statusRepository.delete(post);
}
在我的测试类中，我想做这样的事情
given(statusRepository.delete(any(Post.class))).willReturn(Mono.empty());
有没有更好的方法来做到这一点？
有人能帮我吗？
谢谢。
浏览 114提问于2019-07-24得票数 13
回答已采纳
1回答
我是反应式编程的新手，我有一段代码，只有在并行任务结束后才能并行运行，后面的代码应该被执行
//step 1 parallel stuff
Flux.fromIterable( sourceOneMap.keySet() )
.parallel()
.runOn( Schedulers.parallel() )
.subscribe( compId -> {
Mono.just( compId )
.then( checkIfSystemTwoContainsSystemOneInfo(compId,sourceOneMap,sourceTwoMap,new Timestamp( n
浏览 2提问于2018-12-07得票数 0
2回答
我有一个网络服务，返回学生和注册班级的详细信息.
{
"name": "student-name",
"classes": [
{
"className": "reactor-101",
"day": "Tuesday"
},
{
"className": "reactor-102",
"day": "Friday"
}
]
}
浏览 4提问于2017-09-14得票数 5
回答已采纳
这是我的HandlerFunction public Mono<ServerResponse> getTime(ServerRequest serverRequest) {
return time(serverRequest).onErrorReturn("some errors has happened !").flatMap(s -> {
// this didn't called
return ServerResponse.ok().contentType(MediaType.TEXT_PLAI
浏览 34提问于2019-02-15得票数 1
回答已采纳
在非反应式应用程序中，我们可以使用SecurityContextHolder.getContext().setAuthentication(authentication);以编程方式对请求进行身份验证。 Webflux的等价物是什么？ public class ReactiveServiceAuthenticationFilter implements WebFilter {
private final ReactiveAuthenticationManager authenticationManager;
public ReactiveServiceAuthentica
浏览 108提问于2020-04-24得票数 0
回答已采纳
1回答
我需要在集群中运行一些作业，一次只能运行一个作业。因为我的团队使用Hazelcast，所以我最终得到了一个基于Hazelcast 实现的解决方案。为了这个问题的目的，我将对此作一个概括。让我们假设我们有以下接口(这些接口可以很容易地实现，例如，由Hazelcast或Reddison (Redis)实现)：
public interface MyDistributedLock {
boolean lock();
void unlock();
boolean isLockedByCurrentThread();
}
public interface MyLockDi
浏览 0提问于2019-01-26得票数 0
回答已采纳
我正在尝试探索使用drools的反应性编程。我正在做POC来对对象应用drools规则。
public Mono<Order> findByOrderNo(String orderNo) {
Mono<Order> order = orderDAO.findByOrderNo ( orderNo );
KieSession kieSession = kieContainer.newKieSession("rulesSessionpart2");
kieSession.insert(order);
浏览 2提问于2020-06-16得票数 0
我正在学习Spring，在编写示例应用程序的过程中，我发现了与Spring WebFlux结合使用的反应式类型(Mono/Flux)相关的一个问题。
考虑下面的代码片段(用Kotlin编写)：
@Repository
interface TaskRepository : ReactiveMongoRepository<Task, String>
@Service
class TaskService(val taskRepository: TaskRepository) {
@Cacheable("tasks")
fun get(id: Strin
浏览 4提问于2018-01-09得票数 25
回答已采纳
1回答
我有一大堆对象，我需要使用反应式方法来过滤它们。既然filter不支持反应式类型，我怎么才能做到这一点？ Flux<Student> students = ...
students
.filter(this::leavesNearby)
.collectList();
Mono<Boolean> leavesNearby(Student student) {
Address address = student.getAddress;
return addressService.isNearby(address);
} 考虑到addr
浏览 17提问于2021-06-23得票数 0
回答已采纳
过滤器的filter()方法如下所示：
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return chain.filter(exchange).doFinally(signal -> {
LOGGER.info("Signal: " + signal.name()); // never says CANCEL
// ...
});
}
}
我需要
浏览 22提问于2021-05-22得票数 0
假设:使用webflux的反应式系统，使用jdbc驱动程序的传统spring数据，我如何使用以下方法管理事务： Mono<TrxResponse> doTrx(){
return Mono.fromCallable(() -> parentRepository.save(parent))
.flatMap(parent()-> {
return Mono.fromCallable(() -> childRepository.save(child)})
浏览 115提问于2021-11-05得票数 1
我有一个反应式rest应用程序，它使用了springboot。使用jetty作为后端。
如何通过Appengine公开flux和mono rest端点？有办法做到这一点吗？
google appengine是否支持自己的基于反应式java的api端点？
浏览 0提问于2019-01-16得票数 1
1回答
在HTTP端点处理程序方法中使用Mono作为参数有什么好处？
假设我有这样的代码：
public Mono<ResponseDto> handle (@RequestBody Mono<RequestBodyDto> requestBody) {
return requestBody
.flatMap(service::doSomething)
.doOnError(%printError with requestBody%);
}
我希望将请求记录在错误日志中，但在处理lambda错误时，我没有访问它的权限。我不能打电话给requ
浏览 1提问于2022-02-18得票数 0
回答已采纳
关于webflux reactive存储库的小问题，特别是关于Flux saveAll(Iterable Var1)和Flux saveAll(Publisher Var1)的方法； 为了进行比较，我写了以下内容： @Controller
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class);
}
@Autowired
private
浏览 119提问于2020-09-01得票数 1
回答已采纳
我正在使用spring data couchbase，我想编写一个自定义查询，用于根据我写下的以下查询条件删除所有文档： @Query("#{#n1ql.delete} WHERE #{#n1ql.filter} AND " +
"accountId = $1 #{#n1ql.returning}")
Mono<Void> delete(String accountId); 但这似乎并不管用。请帮助我解决此问题。
浏览 21提问于2021-07-19得票数 1
2回答
我正在尝试模拟订阅方法中的两个使用者接口。
ConsumerService.java
@Autowired
ConsumerDao consumerDao;
public void insertStatus(){
SchedularStatus schedularStatus = new SchedularStatus();
Mono<Object> savedConsumer = consumerDao.save(schedularStatus);
savedConsumer.subscribe(success -> Log.info(
浏览 6提问于2022-09-25得票数 0
回答已采纳
我有一个看起来像这样的方法。 @GetMapping
Some read() {
return getSome();
} 现在，我希望将结果的类型更改为非反应性，保留getSome() - Mono。 问题是哪一个更好？或者，它们在反应式系统的上下文中是等效的吗？ @GetMapping
Mono<Some> read() {
return Mono.justOrEmpty(getSome()); // getSome() is still non-reactive
}
@GetMapping
Mono<Some> read() {
retu
浏览 115提问于2021-11-11得票数 1
回答已采纳
1回答
我有一个包含以下两个方法的类。 public class Test1 {
public Mono<String> blah1() {
Mono<String> blah = Mono.just("blah1");
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStack
浏览 27提问于2021-11-14得票数 1
回答已采纳
首先需要verify()一些东西，如果一切正常，那么调用get(id)方法来获取实体，否则就不需要调用get(id)了。如何编写verifyThenGet(id)方法的代码？
fun verifyThenGet(id: Int) : Mono<MyEntity> {
return verify().then(get(id)) // also invoke get(id) even verify failed
}
// return Mono.empty() if success to verify,
// otherwise return Mono.error(TheEx
浏览 55提问于2018-08-13得票数 -1
1回答
Mono.zip(
Mono.fromCallable(() -> queueDao.getNumberOfMessageInQueue(cartDaemonUrl)),
Mono.fromCallable(() -> queueDao.getNumberOfMessageInQueue(orderConfirmationDaemonUrl))
//ono.fromCallable(()->queueDao.getNumberOfMessageInQueue(cartDaemonUrl))
)
浏览 0提问于2018-09-20得票数 1
2回答
捕获身份验证异常
、、、
我使用以下代码发送XML请求：
RestClient client = RestClientBuilder.builder()
.gatewayUrl(URL)
.build();
Mono<AuthorizeResponse> result = client.executeAndReceiveAuthorize(request);
response = result.block();
public RestClient(String gateway
浏览 1提问于2019-08-28得票数 4
1回答
我有一个构建在spring mvc上的RESTful应用程序。
最近，我在spring mvc和反应流(如rxjava和project-reactor)之间做了一些集成工作，并试图使应用程序更具反应性。
我刚刚构建了一些如下的演示：
1.对于rxjava，我使用PublishSubject
private SerializedSubject<StreamResult, StreamResult> subject = PublishSubject.<StreamResult>create().toSerialized();
public ReactiveStreamCo
浏览 2提问于2016-05-13得票数 3
1回答
我对响应式编程比较陌生。我的问题是关于Mono::then的
我想做的是，从传入的请求中提取主体，将其设置为静态变量。完成此操作后，发送一个响应，告知服务已启动。但是下面的代码总是返回"Service started for: null“。
我认为Mono::then应该在第一个mono完成后运行(在本例中，在设置静态变量之后)，并返回"Service started for: a，b，c“。
我的理解是错的吗？
(另外，欢迎任何代码批评)
public Mono<ServerResponse> getStatus(ServerRequest req) {
浏览 82提问于2020-02-14得票数 0
回答已采纳
我想知道Reactor类型(Mono和Flux)甚至Rxjava类型是否是Java可完成未来的包装器，还是它们使用自己的实现。
对这件事的任何帮助都将不胜感激。
浏览 0提问于2019-08-13得票数 1
class Test{
public Mono<ServerResponse> test(ServerRequest req){
Mono<String> data = Mono.just("test");
System.out.print(data);
return ServerResponse.ok.body(data, String.class);
}
}
当客户端发出请求时，在第4行打印"MonoJust“，但在Http响应主体中返回"test”。我知道发布者不会在订
浏览 2提问于2021-11-04得票数 1
2回答
onErrorContinue()存在一个问题，即传递给Biconsumer的对象为null。
我使用Spring 2.1.13 reactor和reactive与反应堆核心版本3.2.15.RELEASE。
当调用数据库以检索带有id的记录时，就会出现这样的问题:没有返回记录，使用操作符switchIfEmtpy()，我使用Mono.error()抛出一个异常，下游则尝试使用onErrorContinue()处理这个异常。
下面的守则解释了这个问题：
public static void main(String[] args) {
Flux.range(1, 10)
浏览 0提问于2020-07-10得票数 0
回答已采纳
关于，我想我终于知道了如何像这样从Flux<String>中提取String：
Flux<String> rates = controller.getRate(json);
String myRate = rates.next().subscribe(System.out::print);
但是，这会导致类型不匹配cannot convert from Disposable to String
我到底搞错了什么？
为了澄清，它是为了测试--我需要一个内部字符串值。因此，如果我有一个字符串值：one，two，three，那么我想将另一个字符串
浏览 0提问于2021-03-05得票数 1
我使用的是Spring Integration 5.1.5 (使用spring-integration-amqp的RabbitMQ )，我在docs中读到Spring Integration支持project reactor类型(这里我指的是Mono、Flux等)。但是我不能让这个在ServiceActivator上工作。我尝试这样做： @ServiceActivator
public Mono<Void> myMethod(List<Message> messages) {
Mono<Void> result = myService.doServi
浏览 49提问于2019-05-27得票数 1
回答已采纳
我的标题听起来令人困惑，所以让我用一些命令式伪代码来解释我想要做的事情 Mono<Void> func() {
Mono<MyThing> myThing = getMyThing();
if myThing is not empty:
return doSomething();
else:
return doSomethingElse();
} 这就是我在尝试进行反应性操作时遇到的问题： Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
浏览 484提问于2021-03-31得票数 1
回答已采纳
例如，假设我有一个WebFilter，它编写一些上下文
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
return chain.filter(exchange)
.contextWrite(Context.of("my-context", "foobar"));
}
下游，我的控制器做这件事
@GetMapping(path = "test")
public Mono<String> test() thr
浏览 4提问于2021-04-02得票数 0
我正在尝试在Spring WebFlux中重新创建HttpServletResponse#getWriter功能，但没有成功。
在Spring MVC中，我将扩展HandlerInterceptorAdapter，使用提到的getWriter编写目标响应，并从preHandle方法返回false。我正在尝试使用以下代码重新创建相同的功能。请看下面的摘录，看看我到目前为止还没有成功的尝试。
@Component
public class CustomInterceptor extends RequestMappingHandlerAdapter
@Override
public
浏览 1提问于2018-02-08得票数 1
我正在将我的数据服务转换为使用MongoDB reactive驱动程序。通过我查询信息的方式(同时在几个部分中)，它使我能够更高效、更快速地协调所有活动。 到目前为止，这个API的使用者还没有准备好被转换，所以在将完全实现的对象返回给rest方法返回给客户机之前，我最终调用了Mono.zip(...).blockOptional。但我想知道，即使我的数据服务API的消费者还没有准备好完全转换为响应式，我是否可以从返回Mono中受益，并仍然获得一些好处。 返回Mono会节省两个服务之间的Spring web序列化/反序列化吗？这是目前整个数据流中最昂贵的部分。或者返回Mono和对象本身在时间和
浏览 20提问于2021-05-04得票数 0
回答已采纳
我已经开始学习Spring web flux了。我目前的需求是在我的项目中使用Spring web flux和AMQP。这个项目是使用rabbitmq发布-订阅AMQP消息传递和项目没有网络dependency.This项目将在纯粹的后端工作。
下面是我的demo服务文件，这个服务在消息负载中获取所需的数据，然后服务将根据负载数据进行处理，并完成需要的任务。
public class HandlerService {
@RabbitListener(queues = "${amqp.queue}")
public void consumeMessageFrom
浏览 18提问于2020-03-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
