草庐IT

spring-cloud-starter-stream

全部标签

java - 与基本链接的 Spring Security Kerberos

我有一个关于SpringSecurity的快速问题。我正在寻找一种将安全性集成到我们的应用程序中的解决方案,该应用程序提供SSO,但也提供基本的HTTP。我们系统的一个自动化部分只能支持基本身份验证,我们被它锁定了。目前,我们的目标是将Kerberos用于我们的SSO解决方案,然后还支持基本(非常受限的使用)。所有这些都将保护通过resteasy运行的RESTfulWeb服务。有没有人看到在springsecurity中将Kerberos和BASIC链接在一起的解决方案存在任何固有的不可能性?我们在WildFly和undertow方面遇到了问题,无法支持多种不同的身份验证方法,这些方法

java - ifPresent Stream 的 Else 方法

这个问题在这里已经有了答案:Ifnotnull-java8style(2个答案)关闭7年前。我想知道如果在过滤流后某些值不存在时如何执行某些行为。让我们假设代码:foo.stream().filter(p->p.someField==someValue).findFirst().ifPresent(p->{p.someField=anotherValue;someBoolean=true;});我如何放置某种类型的Else在ifPresent之后如果值不存在?有一些orElse我可以在findFirst之后调用的Stream上的方法,但我看不到用那些orElse来做到这一点的方法

java - 获取 HTTP 状态 400 - 必需的 MultipartFile 参数 'file' 在 spring 中不存在

我正在尝试使用spring上传文件。下面是我的代码,我是如何处理它的但是如果我尝试使用它,我会得到这个响应:HTTP状态400-所需的MultipartFile参数"file"不存在我不明白错误是什么。我正在使用高级Rest客户端进行测试,我正在上传文件作为附件。我的Java代码:@RequestMapping(value="/upload",headers="Content-Type=multipart/form-data",method=RequestMethod.POST)@ResponseBodypublicStringupload(@RequestParam("file")M

Java 8. collection.stream() 和 Stream.of(collection) 的区别

你能给我解释一下吗?为什么Stream.of(l1,l2).flatMap((x)->x.stream()).forEach((x)->System.out.println(x));和Stream.of(l1,l2).flatMap((x)->Stream.of(x)).forEach((x)->System.out.println(x));不同吗? 最佳答案 Stream没有Stream.of(Collection)方法。它确实有一个方法staticStreamof(Tt)如果你传递一个Collection使用这种方法你会得到一个

java - 无法理解这个 Java Stream+Generics 示例

谁能帮我理解为什么这段代码的行为与评论中描述的一样//1)compilesListl=Stream.of(1,2,3).collect(ArrayList::new,ArrayList::add,ArrayList::addAll);/**2)doesnotcompile**Exceptioninthread"main"java.lang.Error:Unresolvedcompilationproblems:*Typemismatch:cannotconvertfromObjectto*ThetypeArrayListdoesnotdefineadd(Object,Integer)t

java - spring-boot-devtools 在从缓存获取时导致 ClassCastException。

我在从缓存中获取值时遇到问题。java.lang.RuntimeException:java.lang.ClassCastException:com.mycom.admin.domain.Usercannotbecasttocom.mycom.admin.domain.User缓存配置@Configuration@EnableCaching@AutoConfigureAfter(value={MetricsConfiguration.class,DatabaseConfiguration.class})@Profile("!"+Constants.SPRING_PROFILE_FAST

java - 一些 Controller 的 Spring mvc 过滤器

我需要处理所有到达某些SpringController的请求,以获取一些请求者信息或抛出安全过滤器等异常。我想知道Spring中是否有内置的东西,比如Controller的过滤器(我不需要它用于所有Controller,但只用于某些Controller)。我不想通过url请求应用此过滤器,而是使用类/方法扩展或注释。这是我的实际解决方案:@ControllerpublicclassMyFilteredControllerextendsFilterController{@RequestMapping("/filtered")publicvoidtest1(HttpServletReque

java - 使用 JSR-303 和 Spring 的 validator 的组合为 spring boot 端点实现自定义验证逻辑

我正在尝试结合使用JSR-303BeanValidationAPI和Spring'sValidator为springboot端点实现一些自定义验证逻辑。根据Validator类图,似乎可以扩展CustomValidatorBean、SpringValidatorAdapter或LocalValidatorFactoryBean之一以添加一些自定义验证逻辑进入重写方法validate(Objecttarget,Errorserrors)。.但是,如果我创建一个validator扩展这三个类中的任何一个并使用@InitBinder注册它,它的validate(Objecttarget,Er

java - Kafka Streams - 处理超时

我正在尝试使用.process()用TimeWindows.of("name",30000)批处理一些KTable值并发送它们。似乎30秒超过了消费者超时间隔,在此之后Kafka认为该消费者已失效并释放分区。我已经尝试提高轮询和提交间隔的频率来避免这种情况:config.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG,"5000");config.put(StreamsConfig.POLL_MS_CONFIG,"5000");不幸的是,这些错误仍在发生:(很多)ERRORo.a.k.s.p.internals.RecordCollector-E

java - Spring Boot - 休息模板和休息模板构建器

据我所知,RestTemplateBuilder是RestTemplate的某种工厂。我有几个关于使用它的问题:在示例中,@Configuration类中经常有这样的内容:@BeanpublicRestTemplategetRestClient(){RestTemplaterestClient=newRestTemplate();...returnrestClient;}RestTemplate不应该为每个@Service类实例化吗?如果可以,如何定制?Spring引用说明RestTemplateBuilder应该通过RestTemplateCustomizer进行自定义。如何使用一个