状态管理
状态管理(State Management)使用键值对作为存储机制,可以轻松的使长时运行、高可用的有状态服务和无状态服务共同运行在我们的服务中。
我们的服务可以利用Dapr的状态管理API在状态存储组件中保存、读取和查询键值对。
状态存储组件是可插拔的,目前支持使用Azure CosmosDB、 Azure SQL Server、 PostgreSQL,、AWS DynamoDB、Redis 作为状态存储介质。
文章持续更新,微信搜索「万猫学社」第一时间阅读,关注后回复「电子书」,免费获取12本Java必读技术书籍。
编写示例代码
创建一个SpringBoot项目,命名为:state-management
,该项目的状态管理调用过程如下图:
在state-management
该项目的pom.xml
文件中添加如下依赖:
io.dapr
dapr-sdk-springboot
1.4.0
com.squareup.okhttp3
okhttp
4.9.3
注入一个DaprClient
的bean:
@Configuration
public class DaprConfig {
private static final DaprClientBuilder BUILDER = new DaprClientBuilder();
@Bean
public DaprClient buildDaprClient() {
return BUILDER.build();
}
}
state-management
项目中一共有3个接口:
-
save
:保存状态 -
get
:读取状态 -
delete
:删除状态
具体源码如下:
package one.more.society.state.management;
import io.dapr.client.DaprClient;
import io.dapr.client.domain.State;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
public class StateManagementController {
@Autowired
private DaprClient client;
private static final String STATE_STORE_NAME = "statestore";
private static final String STATE_STORE_KEY = "one.more.society";
/**
* 保存状态
*
* @param value value
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.GET)
public StateResponse save(String value) {
log.info("save - value:{}", value);
client.saveState(STATE_STORE_NAME, STATE_STORE_KEY, value).block();
StateResponse response = new StateResponse();
response.setCode(1);
response.setStatus("save");
response.setValue(value);
return response;
}
/**
* 读取状态
*
* @return StateResponse
*/
@RequestMapping(value = "/get", method = RequestMethod.GET)
public StateResponse get() {
log.info("get");
State value = client.getState(STATE_STORE_NAME, STATE_STORE_KEY, String.class).block();
log.info("value: {}", value.getValue());
StateResponse response = new StateResponse();
response.setCode(1);
response.setStatus("get");
response.setValue(value.getValue());
return response;
}
/**
* 删除状态
*
* @return
*/
@RequestMapping(value = "/delete", method = RequestMethod.GET)
public StateResponse delete() {
log.info("delete");
client.deleteState(STATE_STORE_NAME, STATE_STORE_KEY).block();
StateResponse response = new StateResponse();
response.setCode(1);
response.setStatus("delete");
return response;
}
}
另外,在application.properties
中配置:
server.port=30003
文章持续更新,微信搜索「万猫学社」第一时间阅读,关注后回复「电子书」,免费获取12本Java必读技术书籍。
启动服务
在启动之前先用mvn
命令打包:
mvn clean package
在state-management
项目的目录中执行以下命令,启动state-management
服务:
dapr run --app-id state-management --app-port 30003 --dapr-http-port 31003 -- java -jar target/state-management-0.0.1-SNAPSHOT.jar
在Dapr Dashboard中看到:
服务都已经启动成功。
先访问http://localhost:30003/get,可以看到:
读取状态返回为null,接下来访问http://localhost:30003/save?value=万猫学社,可以看到:
状态已经保存了,再访问http://localhost:30003/get验证一下:
状态被正确读取,再访问http://localhost:30003/delete,可以看到:
状态已经被删除了,再访问http://localhost:30003/get验证一下:
读取状态返回为null。
文章持续更新,微信搜索「万猫学社」第一时间阅读,关注后回复「电子书」,免费获取12本Java必读技术书籍。
状态储存组件
初始化Dapr后,默认为我们指定的状态储存组件是Redis,在用户目录下的.dapr
文件夹中的components
文件夹中,可以找到statestore.yaml
文件:
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: statestore
spec:
type: state.redis
version: v1
metadata:
- name: redisHost
value: localhost:6379
- name: redisPassword
value: ""
- name: actorStateStore
value: "true"
下面让我们来尝试一下,使用MySQL作为状态储存组件,把statestore.yaml
文件修改为:
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: statestore
spec:
type: state.mysql
version: v1
metadata:
- name: connectionString
value: "root:one.more.society@tcp(127.0.0.1:3306)/?allowNativePasswords=true"
重新启动服务,可以看到在日志中看到使用MySQL作为状态储存组件:
time="09:57:35.5632633+08:00" level=info msg="Creating MySql schema 'dapr_state_store'" app_id=state-management instance=JT-243137 scope=dapr.contrib type=log ver=1.7.3
time="09:57:35.5862126+08:00" level=info msg="Creating MySql state table 'state'" app_id=state-management instance=JT-243137 scope=dapr.contrib type=log ver=1.7.3
time="09:57:35.6563599+08:00" level=info msg="component loaded. name: statestore, type: state.mysql/v1" app_id=state-management instance=JT-243137 scope=dapr.runtime type=log ver=1.7.3
如果在MySQL中没有对应的库和表,Dapr默认为我们自动创建一个名为dapr_state_store
的库,还有一个名为state
的表,如下图:
其中,state
的表结构为:
CREATE TABLE `state` (
`id` varchar(255) NOT NULL,
`value` json NOT NULL,
`isbinary` tinyint(1) NOT NULL,
`insertDate` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
`updateDate` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`eTag` varchar(36) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
再访问一下http://localhost:30003/save?value=万猫学社,就可以在数据库中看到对应的数据:
值得注意的是:MySQL状态储存组件目前还处于Alpha状态,最好不要在生产环境使用。
更详细的配置说明见下表:
配置项 | 是否必填 | 说明 | 示例 |
---|---|---|---|
connectionString | Y | 用于连接到 MySQL 的连接字符串。 请不要将schema添加到连接字符串中。 | 非SSL连接: ":@tcp(:3306)/?allowNativePasswords=true" Enforced SSL 连接: ":@tcp(:3306)/?allowNativePasswords=true&tls=custom"
|
schemaName | N | 要使用的schema名称。 如果指定的schema不存在,将会自动创建。默认值为"dapr_state_store"
|
"one_more_state_store" |
tableName | N | 要使用的表名。如果对应的表不存在,将被自动创建。默认值为 “state” | "one_more_state" |
pemPath | N | 使用 Enforced SSL 连接 时,指定要使用的 PEM 文件完整路径。 | “/one/more/society/file.pem” |
pemContents | N | 如果没有提供pemPath,用于Enforced SSL连接的PEM文件的内容。可以在K8s环境下使用。 | “pem value” |
配置示例:
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: statestore
spec:
type: state.mysql
version: v1
metadata:
- name: connectionString
value: "root:one.more.society@tcp(127.0.0.1:3306)/?allowNativePasswords=true&tls=custom"
- name: schemaName
value: "one_more_state_store"
- name: tableName
value: "one_more_state"
- name: pemPath
value: "/one/more/society/file.pem"
微信公众号:万猫学社
微信扫描二维码
关注后回复「电子书」
获取12本Java必读技术书籍
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
机房租用,北京机房租用,IDC机房托管, http://www.fwqtg.net
相关推荐: 【专题】工业4.0时代:2022年重塑行业未来调查报告PDF合集分享(附原数据表)
报告链接:http://tecdat.cn/?p=32361 原文出处:拓端数据部落公众号 这份报告探讨了公司主管们对于新科技的看法,并探讨了他们对于5G、物联网的投资方案,同时也探讨了公司对于提供商和合作生态系统的看法。最后,根据本研究之发现,提出相关之建议…