java11 mysql示例

快速部署一个 java11 的 Event 类型的读写 Mysql 数据库函数到阿里云函数计算。在本案例中提供公网方式连接到 RDS MySQL数据库。

前期准备

使用该项目，推荐您拥有以下的产品权限 / 策略：

| 服务/业务 | 函数计算 |
| --- | --- |
| 权限/策略 | AliyunFCFullAccess |

使用该项目，您需要提前准备好 MySQL 数据库并执行以下 SQL 语句创建表:

    CREATE TABLE `users` (
      `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
      `name` varchar(20) NOT NULL,
      `age` tinyint(11) NOT NULL DEFAULT '0',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

MySQL 数据库既可以选择阿里云 MySQL 数据库也可以选择其它 MySQL 数据库。在本案例中我们使用公网方式连接到阿里云 MySQL 数据库，若使用vpc方式连接阿里云 MySQL 数据库，请参考文档配置网络配置VPC网络。

使用阿里云数据库RDS MySQL实例,创建教程可以参考这里
- 登陆 RDS 控制台为 MySQL 实例申请外网地址,便于公网访问数据库
- 设置 IP 白名单,本案例作为测试，可以将白名单配置成 0.0.0.0/0。（不要在生产环境使用!)
- 需要提供正确的数据库 URL 地址、数据库名称、用户、密码，用于连接数据库
使用其它 MySQL 数据库
- 需要提供正确的数据库 URL 地址、数据库名称、用户、密码，用于连接数据库

快速开始

方式一、使用控制台创建

1. 编译打包

# 编译部署
mvn package
# 打包文件
cd target && zip -r java11-mysql.zip *

2. 创建函数

选择服务（或创建服务）后，单击创建函数，如图所示

选择 从零开始创建
填入函数名称
选择运行环境 java11/java8
选择函数触发方式：通过事件请求触发
其他设置使用默认

详细创建函数流程见文档: 使用控制台创建函数

3. 设置initializer/preStop回调函数配置和环境变量配置

回调函数配置

环境变量配置

4. 测试函数

返回结果如下所示

{name=wanger, id=3, age=5}

方式二、使用 Serverless Devs 工具编译部署

1. 修改 s.yaml 配置

根据需要修改 access 配置
修改 environmentVariables 配置，填入 JDBC_URL, JDBC_USER 和 JDBC_PASSWORD

环境变量

| 参数名称 | 参数类型 | 是否必填 | 例子 | 参数含义 | | --- | --- | --- | --- | --- | | MYSQL_ENDPOINT | String | 必填 | rm-uf6rrswxxxxxxxxxxxx.mysql.rds.aliyuncs.com | 数据库网址，用于连接数据库 | | MYSQL_PORT | String | 必填 | 3306 | 数据库端口 | | MYSQL_DBNAME | String | 必填 | test | 数据库名称 | | MYSQL_USER | String | 必填 | fc | 数据库用户名 |
| MYSQL_PASSWORD | String | 必填 | xxxxxxxx | 数据库密码 |

2. 部署

s deploy

3. 调用测试

使用 Serverless Devs Cli 调试

运行 s invoke 进行远程调试

调用函数时收到的响应如下所示:

========= FC invoke Logs begin =========
FC Initialize Start RequestId: 9fe60072-7fe2-4f62-9d13-xxxxxxx
[Name] Register [com.aliyun.serverless.runtime.classloader.FunctionClassLoader@58372a00] as [com.aliyun.serverless.runtime.classloader.FunctionClassLoader@com.aliyun.serverless.runtime.classloader.FunctionClassLoader@/code/HelloFCJava-1.0-SNAPSHOT.jar/code/original-HelloFCJava-1.0-SNAPSHOT.jar]: hash [8bbd2e0] (normal mode)
2022-07-19 04:21:54.577 [INFO] [9fe60072-7fe2-4f62-9d13-62fc04156f77] database connection time cost: 397ms
FC Initialize End RequestId: 9fe60072-7fe2-4f62-9d13-xxxxxxx
FC Invoke Start RequestId: 7581b7c4-bb40-4690-90d6-xxxxxxx
2022-07-19 04:21:59.539 [INFO] [7581b7c4-bb40-4690-90d6-xxxxxxx] Success - 1 rows affected.
2022-07-19 04:21:59.613 [INFO] [7581b7c4-bb40-4690-90d6-xxxxxxx] get user: {name=wanger, id=3, age=5}
FC Invoke End RequestId: 7581b7c4-bb40-4690-90d6-xxxxxxx
Duration: 108.03 ms, Billed Duration: 109 ms, Memory Size: 128 MB, Max Memory Used: 109.13 MB
========= FC invoke Logs end =========
FC Invoke instanceId: c-62d63161-a82af772bxxxxxxx
FC Invoke Result:
{name=wanger, id=3, age=5}
End of method: invoke

端对端测试
- 登陆 FC 控制台并测试函数
- 控制台返回结果如下所示:
```
{name=wanger, id=3, age=5}
```
  数据库访问限制
- 使用云数据库时，一般都会有访问控制，需要设置 IP 白名单,本案例作为测试，可以将白名单配置成 0.0.0.0/0。（不要在生产环境使用!)。
- 在生产环境，可以使用以下两种方式访问：
- VPC方式（推荐）参考文档：配置网络
- 公网方式参考文档：配置固定公网IP地址
- 本示例不是连接池方式，若要使用连接池，可以参考文档 Connection Pooling with Connector/J

本应用仅作为学习和参考使用，您可以基于本项目进行二次开发和完善，实现自己的业务逻辑

常见问题

未设置白名单，MySQL 网址或端口设置错误

 "errorMessage": "Communications link failure\n\nThe last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server."

MySQL 用户名、密码错误

 "errorMessage": "Access denied for user 'fc'@'120.76.207.131' (using password: YES)"

MySQL 数据库名称错误

 "errorMessage": "Unknown database 'users1'"

README.md 6.2 KB تاريخچه خام