濮阳网站建设优化,代理公司注册变更,做企业官网需要注意什么,常州市做网站的公司netty java使用Okta的身份管理平台轻松部署您的应用程序 使用Okta的API在几分钟之内即可对任何应用程序中的用户进行身份验证#xff0c;管理和保护。 今天尝试Okta。 Netty是一个无阻塞输入/输出#xff08;NIO#xff09;框架#xff0c;它使开发低级网络服务器和客户端… netty java 使用Okta的身份管理平台轻松部署您的应用程序 使用Okta的API在几分钟之内即可对任何应用程序中的用户进行身份验证管理和保护。 今天尝试Okta。 Netty是一个无阻塞输入/输出NIO框架它使开发低级网络服务器和客户端变得相对简单。 Netty为需要在套接字级别上工作的开发人员提供了令人难以置信的强大功能例如在开发客户端和服务器之间的自定义通信协议时。 它支持SSL / TLS具有阻塞和非阻塞统一API以及灵活的线程模型。 它又快又高效。 Netty的异步非阻塞I / O模型是为高度可扩展的体系结构设计的与类似的阻塞模型相比它可能允许更高的吞吐量。 基本上非阻塞服务器在单个线程上异步运行所有请求没有函数应“阻塞”事件循环。 这与阻塞服务器模型形成对比后者通常在单独的线程上运行每个请求。 通过不必在负载增加时切换线程或创建新线程非阻塞模型可以减少开销并随着流量增加而更快地进行扩展。 但是所有这些功能都是以复杂性为代价的。 非阻塞代码通常更难阅读测试和维护尽管随着异步范例的成熟非阻塞代码已大大改善。 由于Netty在套接字级别工作因此还需要更深入地了解诸如线程循环字节缓冲区和内存管理之类的细节。 Netty.io团队做了出色的工作使Netty的所有功能易于使用但是它仍然比高级库例如Spring Boot WebFlux更加复杂。 那么为什么要使用它呢 Netty旨在使自定义网络协议的实现相对容易。 HTTP很不错但是它是一种通用协议基本上适合大多数情况。 但是如果您始终在服务器和客户端之间来回传递自定义的结构化数据大型文件流媒体实时游戏数据等则可以做得更好。 Netty允许您编写适合自己特定需求的自己的网络协议针对特定情况优化流量而没有HTTP或FTP之类的不必要开销。 但是即使您不打算编写自己的自定义TCP协议也可以使用Netty的功能。 Spring WebFlux是Spring对非阻塞和React式编程的解答。 它是传统阻塞Spring MVC体系结构的替代方案。 默认情况下Spring Boot WebFlux Starter在嵌入式Netty服务器上运行。 在此配置中您可以将WebFlux视为基于Netty的NIO套接字优势构建的React性非阻塞HTTP应用程序层。 在本教程中您将在Netty中创建一个基本的“ Hello world”应用程序。 接下来您将在Spring Boot WebFlux中创建相同的“ Hello world”应用程序。 最后您将使用Okta作为OAuth 2.0提供程序将OAuth 2.0登录名添加到应用程序中。 安装项目依赖项 在开始之前该项目需要安装一些必需的工具。 Java 11 该项目使用Java11 。您可以按照OpenJDK网站上的说明或使用SDKMAN来安装OpenJDK。 HTTPie 这是一个简单的命令行实用程序用于发出将用于测试REST应用程序的HTTP请求。 Okta开发人员也喜欢它。 按照其网站上的说明进行安装 。 Okta开发人员帐户 您将Okta用作OAuth / OIDC提供程序以向应用程序添加OAuth2登录身份验证。 如果尚未注册免费的Okta开发者帐户 请注册。 您还应该继续克隆该博客的GitHub存储库 。 git clone https://github.com/oktadeveloper/okta-netty-webflux-example.git 该项目包含三个子目录分别对应于本教程的三个部分 netty-hello-world 如何创建Netty服务器的非常基本的示例 webflux-hello-world 如何在Spring WebFlux中创建相同的服务器 webflux-oauth2login 如何将OAuth2登录添加到Spring WebFlux应用程序的示例 使用Netty构建HTTP服务器 HTTP服务器是HTTP协议OSI第7层的应用层实现因此在Internet堆栈中相对较高。 如果您正在开发REST API 那么您将在为您提供此实现的API的基础上进行开发 。 相比之下Netty并不一定要构建通信提供会话管理甚至提供像TLS这样的安全性。 如果您要构建超低级网络应用程序那就太好了 但是如果您正在构建REST服务则可能不是最佳选择。 幸运的是Netty API还提供了一些帮助程序类和函数这些类和函数使我们能够轻松集成更高级别的协议例如HTTP。 在本部分的教程中您将使用它们来构建一个简单的HTTP服务器。 在您喜欢的IDE或文本编辑器中打开netty-hello-world项目。 首先查看src/main/java/com/okta/netty/AppServer.java文件。 此类是应用程序的入口点用于设置Netty服务器。 package com.okta.netty; ...public class AppServer { private static final int HTTP_PORT 8080; public void run() throws Exception { // Create the multithreaded event loops for the serverEventLoopGroup bossGroup new NioEventLoopGroup(); EventLoopGroup workerGroup new NioEventLoopGroup(); try { // A helper class that simplifies server configuration ServerBootstrap httpBootstrap new ServerBootstrap(); // Configure the serverhttpBootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ServerInitializer()) // -- Our handler created here .option(ChannelOption.SO_BACKLOG, 128) .childOption(ChannelOption.SO_KEEPALIVE, true); // Bind and start to accept incoming connections. ChannelFuture httpChannel httpBootstrap.bind(HTTP_PORT).sync(); // Wait until server socket is closedhttpChannel.channel().closeFuture().sync(); } finally { workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } } public static void main(String[] args) throws Exception { new AppServer().run(); } } 最重要的一行是.childHandler(new ServerInitializer()) 它创建ServerInitializer和ServerHandler并挂接到Netty服务器。 接下来查看src/main/java/com/okta/netty/ServerInitializer.java 。 此类配置Netty通道该通道将处理我们的请求并将其连接到ServerHandler 。 package com.okta.netty; ...public class ServerInitializer extends ChannelInitializerChannel { Override protected void initChannel(Channel ch) { ChannelPipeline pipeline ch.pipeline(); pipeline.addLast(new HttpServerCodec()); pipeline.addLast(new HttpObjectAggregator(Integer.MAX_VALUE)); pipeline.addLast(new ServerHandler()); } } 最后有src/main/java/com/okta/netty/ServerHandler.java 。 这是映射实际请求并生成响应的地方。 package com.okta.netty; ...public class ServerHandler extends SimpleChannelInboundHandler{ Override protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest msg) { ByteBuf content Unpooled.copiedBuffer(Hello World!, CharsetUtil.UTF_8); FullHttpResponse response new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content); response.headers().set(HttpHeaderNames.CONTENT_TYPE, text/html); response.headers().set(HttpHeaderNames.CONTENT_LENGTH, content.readableBytes()); ctx.write(response); ctx.flush(); } } 在此类中请注意您必须将响应字符串转换为字节缓冲区。 实际上您会生成一个HTTP响应并直接设置一些标头。 这是Internet的应用层OSI第7层。 调用ctx.write(response) 它将响应作为字节流通过TCP发送。 Netty团队在保持低水平的传输协议的同时为隐藏大量的复杂性做了出色的工作。 测试您的Netty应用 要测试此Netty应用程序请从项目根目录netty-hello-world运行 ./gradlew run 一旦应用程序完成了加载就从另一个外壳程序中使用HTTPie执行GET请求 $ http :8080HTTP/1.1 200 OK
content-length: 12
content-type: text/htmlHello World! 那是Netty内置的简单HTTP服务器。 接下来您将爬上梯级的抽象阶梯并使用Spring Boot和WebFlux简化操作。 在Netty上向WebFlux打个招呼 如前所述WebFlux是Spring MVC的无阻塞替代方案。 它通过事件驱动异步和非阻塞方法来处理请求从而支持React式编程。 它还提供了许多功能性API。 Reactor是与Spring紧密合作开发的React性服务器端Java库提供了WebFlux的React流方面。 但是您也可以使用其他React式流库。 回想一下默认情况下Spring Boot WebFlux启动程序在Netty服务器上运行。 在下一个示例中您会注意到Spring Boot隐藏了多少复杂性。 Spring Boot WebFlux项目位于GitHub存储库的webflux-hello-world子目录中。 非常简单。 看一看ReactiveApplication类。 这是准系统的标准Spring Boot应用程序类。 它只是利用public static void main()方法和SpringBootApplication来启动整个Spring Boot应用程序框架。 src/main/java/com/okta/webflux/app/ReactiveApplication.java package com.okta.webflux.app; ... SpringBootApplication
public class ReactiveApplication { public static void main(String[] args) { SpringApplication.run(ReactiveApplication.class, args); } } ReactiveRouter是一个简单的路由器类它将HTML端点与处理程序方法链接在一起。 您可以看到它使用依赖注入将ReactiveHandler传递给路由器bean该bean为/路由定义了一个端点。 src/main/java/com/okta/webflux/app/ReactiveRouter.java package com.okta.webflux.app; ...Configuration
public class ReactiveRouter { Bean public RouterFunctionroute(ReactiveHandler handler) { return RouterFunctions .route(RequestPredicates .GET(/) .and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), handler::hello); }
} ReactiveHandler同样简单。 它定义了一个返回纯文本的处理函数。 MonoServerResponse返回类型是一种特殊类型用于返回一个元素的流。 查看有关了解React类型的Spring文档以了解有关返回类型的更多信息。 如果您习惯使用Spring MVC则这可能是WebFlux更不熟悉的方面之一。 package com.okta.webflux.app; ...Component
public class ReactiveHandler { public MonoServerResponse hello() { return ServerResponse .ok() .contentType(MediaType.TEXT_PLAIN) .body(BodyInserters.fromObject(Hello world!)); } } 打开一个外壳然后导航到项目的webflux-hello-world子目录。 使用以下项目运行项目 ./gradlew bootRun 。 打开另一个外壳以使用http :8080测试端点。 HTTP/1.1 200 OK
Content-Length: 12
Content-Type: text/plainHello world! 看到使用Spring Boot比Netty简单多少 创建一个OpenID ConnectOIDC应用程序 接下来您将使用OAuth 2.0登录名来保护应用程序。 这听起来可能很复杂但是不用担心。 Spring和Okta密谋使其变得非常简单 Okta是SaaS软件即服务身份验证和授权提供者。 我们为开发人员提供免费帐户因此您可以轻松开发OIDC应用程序。 前往developer.okta.com并注册一个帐户。 验证电子邮件后登录并执行以下步骤如果这是您第一次登录则可能需要单击黄色的“ 管理”按钮才能进入开发人员仪表板 转到应用程序 添加应用程序 。 选择应用程序类型Web 然后单击下一步 。 为应用命名。 我将其命名为“ WebFlux OAuth”。 在登录重定向URI下 将值更改为http://localhost:8080/login/oauth2/code/okta 。 其余的默认值将起作用。 单击完成 。 请注意底部的客户端ID和客户端密钥 。 稍后您将需要它们。 使用OAuth 2.0保护您的应用安全 在Okta上创建OIDC应用程序后需要在项目中进行一些更新。 如果您想跳过本部分教程的完成项目可以在webflux-oauth2login子目录中找到但是我将向您展示如何修改webflux-hello-world以添加login 。 首先将Okta Spring Boot Starter添加到Gradle构建文件中。 我们一直在努力使这一过程尽可能容易并且Okta Spring Boot Starter简化了OAuth配置。 看看入门的GitHub项目了解更多信息。 将以下依赖项添加到build.gradle文件的依赖项块中 dependencies { ...implementation com.okta.spring:okta-spring-boot-starter:1.3.0
} 接下来将以下属性添加到src/main/resources/application.properties文件。 您需要将括号中的值替换为您自己的Okta域和客户端ID。 您可以通过打开Okta开发人员仪表板并转到API 授权服务器并在默认服务器的表中查找来找到您的Issuer URI。 客户端ID和机密来自您刚才创建的OIDC应用程序。 okta.oauth2.issuer{yourIssuerUri}
okta.oauth2.client-id{yourClientId}
okta.oauth2.client-secret{yourClientSecret} 现在运行应用程序 ./gradlew bootRun 。 注销您的Okta开发人员帐户或使用隐身窗口并浏览至在浏览器中 http// localhost8080 。 系统将指导您使用Okta帐户登录。 登录后您将被重定向回该应用程序。 是的-成功 了解有关NettySpring Boot和OAuth 2.0的更多信息 在本教程中您使用Netty创建了一个基本的“ Hello world”应用程序。 您已经看到Netty是一个用于创建TCP和UDP网络协议的超强大框架。 您已经了解了它如何支持非阻塞IO以及Spring WebFlux如何在Netty之上构建以提供React性非阻塞HTTP应用程序框架。 然后您在WebFlux中构建了一个“ Hello world”应用程序此后您使用Okta作为OAuth 2.0 / OIDC提供程序来向该应用程序添加OAuth 2.0登录名。 您可以在oktadeveloper / okta-netty-webflux-example上在GitHub上查看本教程的完整代码。 除了WebFlux在Netty之上还构建了一些强大的网络框架。 Apple最近开放了ServiceTalk的源代码 ServiceTalk是一个支持HTTPHTTP / 2和gRPC的React性微服务客户端/服务器库。 还有一个Armeria 一个基于Java 8NettyThrift和gRPC构建的开源异步HTTP / 2 RPC / REST客户端/服务器库。 它的主要目标是帮助工程师构建高性能的异步微服务。 如果您想了解有关Spring BootSpring WebFlux和OAuth 2.0的更多信息请查看以下有用的教程 Spring BootOAuth 2.0和Okta入门 使用Spring WebFlux构建React性API OAuth到底是什么 Spring Security 5.0和OIDC入门 身份声明和令牌– OpenID Connect入门第1部分共3部分 使用Spring Boot和GraphQL构建安全的API 如果您对此帖子有任何疑问请在下面添加评论。 有关更多精彩内容 请在Twitter上关注oktadev或订阅我们的YouTube频道 使用Okta的身份管理平台轻松部署您的应用程序 使用Okta的API在几分钟之内即可对任何应用程序中的用户进行身份验证管理和保护。 今天尝试Okta。 翻译自: https://www.javacodegeeks.com/2020/01/a-quick-guide-to-java-on-netty.htmlnetty java
