没有合适的资源？快使用搜索试试~ 我知道了~

首页Reactive_Microservices_Architecture.pdf

Reactive_Microservices_Architecture.pdf

micro

5星 · 超过95%的资源需积分: 10 138 下载量 159 浏览量更新于2023-03-16 评论 3 收藏 9.54MB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

试读

54页

原typesafe（scala语言创建公司，现在更名LightBend）CTO的小册子，微服务从理论到实践，老司机带你飞。所有关心微服务的都可以看看

资源详情

资源评论

资源推荐

Jonas Bonér

Design Principles for Distributed Systems

Reactive

Microservices

Architecture

Compl

ime

nts

Jonas Bonér

Reactive Microservices

Architecture

Design Principles

for Distributed Systems

Boston Farnham Sebastopol

Tokyo

Beijing Boston Farnham Sebastopol

Tokyo

Beijing

978-1-491-95934-3

[LSI]

Reactive Microservices Architecture

by Jonas Bonér

Printed in the United States of America.

Published by O’Reilly Media, Inc., 1005 Gravenstein Highway North, Sebastopol, CA

95472.

O’Reilly books may be purchased for educational, business, or sales promotional use.

Online editions are also available for most titles (http://safaribooksonline.com). For

more information, contact our corporate/institutional sales department:

800-998-9938 or corporate@oreilly.com.

Editor: Brian Foster

Production Editor: Colleen Cole

Copyeditor: Colleen Toporek

Interior Designer: David Futato

Cover Designer: Karen Montgomery

Illustrator: Kevin Webber

March 2016: First Edition

Revision History for the First Edition

2016-03-15: First Release

The O’Reilly logo is a registered trademark of O’Reilly Media, Inc. Reactive Microser‐

vices Architecture, the cover image, and related trade dress are trademarks of O’Reilly

Media, Inc.

While the publisher and the author have used good faith efforts to ensure that the

information and instructions contained in this work are accurate, the publisher and

the author disclaim all responsibility for errors or omissions, including without limi‐

tation responsibility for damages resulting from the use of or reliance on this work.

Use of the information and instructions contained in this work is at your own risk. If

any code samples or other technology this work contains or describes is subject to

open source licenses or the intellectual property rights of others, it is your responsi‐

bility to ensure that your use thereof complies with such licenses and/or rights.

Table of Contents

1. Introduction. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 1

Services to the Rescue 3

Slicing the Monolith 3

SOA Dressed in New Clothes? 5

2. What Is a Reactive Microservice?. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 7

Isolate All the Things 8

Act Autonomously 11

Do One Thing, and Do It Well 12

Own Your State, Exclusively 13

Embrace Asynchronous Message-Passing 17

Stay Mobile, but Addressable 22

3. Microservices Come in Systems. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 27

Systems Need to Exploit Reality 28

Service Discovery 30

API Management 32

Managing Communication Patterns 34

Integration 35

Security Management 38

Minimizing Data Coupling 41

Minimizing the Cost of Coordination 42

Summary 47

iii

剩余53页未读，继续阅读

ucdos123

2016-11-24

资源合集，看起来方便。针对AWS的架构特点，讲解得很详细

java.lang.IllegalStateException: Only one connection receive subscriber allowed. at reactor.netty.channel.FluxReceive.startReceiver(FluxReceive.java:182) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): checkpoint ⇢ springfox.boot.starter.autoconfigure.SwaggerUiWebFluxConfiguration$CustomWebFilter [DefaultWebFilterChain] checkpoint ⇢ com.texeasy.miniProgram.config.auth.ReactiveRequestContextFilter$1 [DefaultWebFilterChain] checkpoint ⇢ com.texeasy.miniProgram.config.auth.ReactiveRequestContextFilter$$EnhancerBySpringCGLIB$$100afa79 [DefaultWebFilterChain] checkpoint ⇢ com.alibaba.csp.sentinel.adapter.spring.webflux.SentinelWebFluxFilter [DefaultWebFilterChain] checkpoint ⇢ cn.dev33.satoken.reactor.filter.SaReactorFilter [DefaultWebFilterChain] checkpoint ⇢ org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain] *__checkpoint ⇢ HTTP POST "/miniProgram/pay/createOrderV3" [ExceptionHandlingWebHandler]

com.alibaba.csp.sentinel.adapter.spring.webflux.SentinelWebFluxFilter, cn.dev33.satoken.reactor.filter.SaReactorFilter, org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter ...

dataset = pd.read_csv('D:/household_power_consumption/household_power_consumption.txt', sep=';', header=0, low_memory=False, infer_datetime_format=True, engine='c', parse_dates={'datetime':[0,1]}, index_col=['datetime']) dataset.replace('?', np.nan, inplace=True) # 替换异常值 values = dataset.values.astype('float32') # 统一数据类型为float类型，提高精度和速度 dataset["Global_active_power"] = pd.to_numeric(dataset["Global_active_power"],errors='coerce') dataset["Global_reactive_power"] = pd.to_numeric(dataset["Global_reactive_power"],errors='coerce') dataset["Voltage"] = pd.to_numeric(dataset["Voltage"],errors='coerce') dataset["Global_intensity"] = pd.to_numeric(dataset["Global_intensity"],errors='coerce') dataset["Sub_metering_1"] = pd.to_numeric(dataset["Sub_metering_1"],errors='coerce') dataset["Sub_metering_2"] = pd.to_numeric(dataset["Sub_metering_2"],errors='coerce')请把这段代码改成阅读excel格式的数据集

dataset["Global_reactive_power"] = pd.to_numeric(dataset["Global_reactive_power"], errors='coerce') dataset["Voltage"] = pd.to_numeric(dataset["Voltage"], errors='coerce') dataset["Global_intensity"] ...

this._.merge(initialOption.value, option) 转换vue3写法

因此，可以将 `this._.merge(initialOption.value, option)` 改为以下 Vue 3 的写法： ```javascript import { reactive } from 'vue' // 创建一个响应式的对象 const initialOption = reactive({}) // 合并对象 ...

一使用el-button 报(0 , _vue_reactivity__WEBPACK_IMPORTED_MODULE_1__.track)(...) is not a function错误

然后，你可以尝试使用 `reactive` 函数来创建一个响应式对象，并将其传递给 `setup` 函数。例如： ```javascript import { reactive, onMounted } from 'vue'; export default { setup() { const state = ...

引入el-input 报(0 , _vue_reactivity__WEBPACK_IMPORTED_MODULE_1__.track)(...) is not a function错误

这个错误通常是因为在使用 `el-...解决方案可以尝试使用 `ref` 或 `reactive` 来创建响应式对象，而不是直接创建一个普通的 JavaScript 对象。此外，也可以检查一下使用 `el-input` 组件时是否有其他的错误或警告信息。

flutter_reactive_ble

flutter_reactive_ble是用于在Flutter应用程序中实现BLE（蓝牙低功耗）通信功能的插件。它基于Dart语言开发，可以与Flutter框架无缝集成。该插件提供了一套简洁易用的API，可以方便地实现BLE设备的扫描、连接、...

uncaught typeerror: (0 , vue__webpack_imported_module_20__.reactive) is not a function

这是一个 JavaScript 错误，意思是“未捕获的类型错误：(0, vue__webpack_imported_module_20__.reactive) 不是一个函数”。这通常是因为在使用 Vue.js 的响应式数据时出现了问题，可能是因为没有正确导入 Vue.js ...

Flutter BT蓝牙库地址

4. flutter_reactive_ble：https://pub.dev/packages/flutter_reactive_ble 5. flutter_ble_lib：https://pub.dev/packages/flutter_ble_lib 请注意，这些库都是由第三方开发者维护的，因此可能会有不同的功能和...

package com.bolt.gateway.config; import com.bolt.gateway.handler.HystrixFallbackHandler; import com.bolt.gateway.props.AuthProperties; import com.bolt.gateway.props.RouteProperties; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.http.server.reactive.ServerHttpResponse; import org.springframework.web.cors.reactive.CorsUtils; import org.springframework.web.filter.reactive.HiddenHttpMethodFilter; import org.springframework.web.reactive.function.server.RequestPredicates; import org.springframework.web.reactive.function.server.RouterFunction; import org.springframework.web.reactive.function.server.RouterFunctions; import org.springframework.web.server.ServerWebExchange; import org.springframework.web.server.WebFilter; import org.springframework.web.server.WebFilterChain; import reactor.core.publisher.Mono; /** * 路由配置信息 * * @author arch_group */ @Slf4j @Configuration @AllArgsConstructor @EnableConfigurationProperties({RouteProperties.class, AuthProperties.class}) public class RouterFunctionConfiguration { /** * 这里为支持的请求头，如果有自定义的header字段请自己添加 / private static final String ALLOWED_HEADERS = "x-requested-with, zkpt-ks-auth, Content-Type, Authorization, credential, X-XSRF-TOKEN, token, username, client"; private static final String ALLOWED_METHODS = ""; private static final String ALLOWED_ORIGIN = ""; private static final String ALLOWED_EXPOSE = ""; private static final String MAX_AGE = "18000L"; private final HystrixFallbackHandler hystrixFallbackHandler; @Bean public WebFilter corsFilter() { return (ServerWebExchange ctx, WebFilterChain chain) -> { ServerHttpRequest request = ctx.getRequest(); if (CorsUtils.isCorsRequest(request)) { ServerHttpResponse response = ctx.getResponse(); HttpHeaders headers = response.getHeaders(); headers.add("Access-Control-Allow-Headers", ALLOWED_HEADERS); headers.add("Access-Control-Allow-Methods", ALLOWED_METHODS); headers.add("Access-Control-Allow-Origin", ALLOWED_ORIGIN); headers.add("Access-Control-Expose-Headers", ALLOWED_EXPOSE); headers.add("Access-Control-Max-Age", MAX_AGE); headers.add("Access-Control-Allow-Credentials", "true"); if (request.getMethod() == HttpMethod.OPTIONS) { response.setStatusCode(HttpStatus.OK); return Mono.empty(); } } return chain.filter(ctx); }; } @Bean public RouterFunction routerFunction() { return RouterFunctions.route( RequestPredicates.path("/fallback") .and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), hystrixFallbackHandler); } /** * 解决springboot2.0.5版本出现的 Only one connection receive subscriber allowed. * 参考：https://github.com/spring-cloud/spring-cloud-gateway/issues/541 */ @Bean public HiddenHttpMethodFilter hiddenHttpMethodFilter() { return new HiddenHttpMethodFilter() { @Override public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) { return chain.filter(exchange); } }; } }

这是一个Spring Cloud Gateway的路由配置类。它使用了函数式编程风格来定义路由规则。在这个类中，主要做了以下几件事情： 1. 配置跨域请求的过滤器(corsFilter)：当请求的Origin与服务端的地址不一致时，浏览器会...

ieee33计算无功补偿量python实现

data['total_reactive_power'] = data['reactive_power'] + data['transformer_reactive_power'] ``` 4. 计算无功补偿容量根据节点的总无功功率和补偿装置的容量，可以计算无功补偿量。 ```python # 计算无功...

用python写一段电力系统优化的代码

reactive_power = np.asarray(reactive_power) power = active_power + 1j * reactive_power # 计算每个节点的电流 current = np.dot(np.transpose(impedance), power / np.conj(bus_voltage)) # 计算每根线路...

优化此代码 const openKeys = ref<string[]>([]) const selectedKeys = ref<string[]>([]) const { currentMenu, currentMenuTree, currentMenuList } = storeToRefs( useLayoutStore(), ) const rootSubmenuKeys = currentMenuList.value.filter((v: any) => { if (v.type === 0) { return v.parentId } }) watch( () => currentMenu, () => { openKeys.value = [currentMenu.value?.parentId] selectedKeys.value = [currentMenu.value?.id] }, { immediate: true }, ) const router = useRouter() /** * 点击事件 * @param e 事件对象 */ const handleClick = (e: any) => { const item = currentMenuList.value.find((_) => _.id === e.key) if (item) { router.push(item.path) } } /** * SubMenu 展开/关闭的回调 * @param e 展开的openKeys */ const onOpenChange = (e: any) => { const latestOpenKey = e.find((key: any) => openKeys.value.indexOf(key) === -1) if (rootSubmenuKeys.indexOf(latestOpenKey) === -1) { openKeys.value = e } else { openKeys.value = latestOpenKey ? [latestOpenKey] : [] } }

1. Instead of using `ref` for `openKeys` and `selectedKeys`, you can use `reactive` to make the code more concise: ``` const state = reactive({ openKeys: [], selectedKeys: [], }) ``` 2. ...

const items1 = reactive([{ text: "中国", value: "1001" }, { text: "美国", value: "1002" }, { text: "俄罗斯", value: "1003" }])const change1 = ()=>{ console.log(items1.text); }为什么我在change1中拿不到items__1中text的值

你拿不到`items__1`中`text`的值，是因为`items__1`是一个数组，而不是一个对象。数组中的每个元素都是一个对象，每个对象都有自己的`text`属性。如果你要访问`items__1`中的某个对象的`text`属性，你需要指定该对象...

Property or method "nation_list" is not defined on the instance but referenced during render. Make sure that this property is reactive, either in the data option, or for class-based components, by initializing the property.

2. Compute the property: If the `nation_list` property is derived from other reactive properties, you can use a computed property to define it. For example: ```javascript computed: { nation_list() {...

spring cloud gateway 配置cors

import org.springframework.boot.web.reactive.filter.OrderedCorsFilter; import org.springframework.core.Ordered; import org.springframework.http.HttpMethod; import org.springframework.http.HttpStatus; ...

2023-07-14 01:01:42.068 ERROR 17452 --- [nio-8088-exec-1] a.w.r.e.AbstractErrorWebExceptionHandler : [1e611f88] 500 Server Error for HTTP PUT "/trans/getPutUploadUrl?fileName=123.jpg" java.lang.IllegalStateException: No primary or default constructor found for interface javax.servlet.http.HttpServletRequest at org.springframework.web.reactive.result.method.annotation.ModelAttributeMethodArgumentResolver.createAttribute(ModelAttributeMethodArgumentResolver.java:231) ~[spring-webflux-5.2.15.RELEASE.jar:5.2.15.RELEASE] Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): |_ checkpoint ⇢ org.springframework.cloud.gateway.filter.WeightCalculatorWebFilter [DefaultWebFilterChain] |_ checkpoint ⇢ org.springframework.boot.actuate.metrics.web.reactive.server.MetricsWebFilter [DefaultWebFilterChain] |_ checkpoint ⇢ HTTP PUT "/trans/getPutUploadUrl?fileName=123.jpg" [ExceptionHandlingWebHandler] 他报这个错误

import org.springframework.web.reactive.function.server.ServerRequest; public Mono<ServerResponse> handleRequest(ServerRequest request) { // 处理请求逻辑 return ServerResponse.ok().build(); } ``` ...

qq_32431721

粉丝: 0
资源: 1

上传资源快速赚钱

我的内容管理收起

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

会员权益专享

Reactive_Microservices_Architecture.pdf

评论3

会员权益专享

最新资源

Reactive_Microservices_Architecture.pdf

评论3

hands-reactive-programming-spring-5.pdf

java响应式编程(building reactive microservices in java)

Reactive-Microservices-Architecture.pdf

this._.merge(initialOption.value, option) 转换vue3写法

一使用el-button 报(0 , _vue_reactivity__WEBPACK_IMPORTED_MODULE_1__.track)(...) is not a function错误

引入el-input 报(0 , _vue_reactivity__WEBPACK_IMPORTED_MODULE_1__.track)(...) is not a function错误

flutter_reactive_ble

uncaught typeerror: (0 , vue__webpack_imported_module_20__.reactive) is not a function

Flutter BT蓝牙库地址

ieee33计算无功补偿量python实现

用python写一段电力系统优化的代码

const items__1 = reactive([{ text: "中国", value: "1001" }, { text: "美国", value: "1002" }, { text: "俄罗斯", value: "1003" }])const change1 = ()=>{ console.log(items__1.text); }为什么我在change1中拿不到items__1中text的值

Property or method "nation_list" is not defined on the instance but referenced during render. Make sure that this property is reactive, either in the data option, or for class-based components, by initializing the property.

spring cloud gateway 配置cors

推荐几篇 webflux的培训教程

会员权益专享

最新资源

const items1 = reactive([{ text: "中国", value: "1001" }, { text: "美国", value: "1002" }, { text: "俄罗斯", value: "1003" }])const change1 = ()=>{ console.log(items1.text); }为什么我在change1中拿不到items__1中text的值