您现在的位置是：首页 > 文章详情

使用Lambda和API网关在Java中开发RESTful微服务

日期：2018-08-29点击：318收藏

导言

AWS Lambda和AmazonAPI-Gateway可用于在Java中创建RESTfulWeb服务，而无需进行复杂的Java框架配置或设置和维护Web服务器(如Tomcat、WebSphere等)。Lambda和APIGateway的结合使得开发API变得非常容易，并且还可以轻松地管理API的暂存环境，比如开发、测试和Prod。

AWS Lambda是一个高度可伸缩和高度可用的无服务器计算平台，您可以使用它运行Java代码来提供服务的主要功能。有关Lambda的更多信息，请访问链接

(https://aws.amazon.com/documentation/lambda/).

AmazonAPI网关是由AWS提供的一种网络服务，允许开发人员轻松地构建和部署API端点。它使开发人员非常容易地创建HTTPS端点并将其与Lambda函数集成。数据从API端点传递到Lambda函数，并由API网关处理。欲了解更多关于API网关的内容，请访问链接

(https://aws.amazon.com/documentation/apigateway/).

本文提供了关于如何使用Lambda和API网关在Java中开发RESTful微服务的循序渐进的指南。

先决条件

首先，您需要准备一台开发机器，为此您需要Java 8、Eclipse IDE和AWSToolkit for Eclipse。有关如何完成此操作的详细信息，请参阅

(https://www.bluestackcloud.com/insights/2018/5/7/getting-started-with-aws-development-using-java).

白小白：

如果Marketplace闪退，在Eclipse的 Help –> Install New Software，通过在Work with处输入 http://download.eclipse.org/mpc/photon/重新安装。注意，在后续步骤有一个安装组件选择的勾选列表，如果本机没有安装RDS数据库，把关于RDS这一项勾选去掉，否则后续步骤会报错。

步骤1：（环境：Eclipse本地）创建Lambda函数

1. 一旦您准备好使用Eclipse IDE，AWS图标将出现在主工具栏中。点击它并选择“新AWS Lambda项目.”

a33e0290e85d0856e01ca0c872edbaf9cbb8f437

2.提供适当的项目名称和Maven配置。选择“Stream Request Handler”作为输入类型。

d494470ebabd7495fe64cbecd17659dd4968ca9e

3. 在点击“Finish”之后，示例代码将被加载到您新创建的项目中。打开主处理程序函数并更新以下代码。

 package com.amazonaws.lambda.demo; 

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.BufferedReader;

import java.io.Writer;

import java.text.ParseException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.Map;

import com.amazonaws.services.lambda.runtime.RequestStreamHandler;

import com.amazonaws.services.lambda.runtime.Context;

import com.amazonaws.services.lambda.runtime.LambdaLogger;

import org.json.simple.JSONArray;

import org.json.simple.JSONObject;

import org.json.simple.parser.JSONParser;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import com.amazonaws.services.lambda.runtime.Context;

import com.amazonaws.services.lambda.runtime.RequestStreamHandler;

public class LambdaFunctionHandler implements RequestStreamHandler

{

JSONParser parser = new JSONParser();

@Override

public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException

{

LambdaLogger logger = context.getLogger();

logger.log("Loading Java Lambda handler of ProxyWithStream");

String proxy = null;

String param1 = null;

String param2 = null;

BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));

JSONObject responseJson = new JSONObject();

String responseCode = "200";

JSONObject event = null;

try {

event = (JSONObject)parser.parse(reader);

if (event.get("pathParameters") != null) {

JSONObject pps = (JSONObject)event.get("pathParameters");

if ( pps.get("proxy") != null) {

proxy = (String)pps.get("proxy");

}

if (event.get("queryStringParameters") != null)

{

JSONObject qps = (JSONObject)event.get("queryStringParameters");

if ( qps.get("param1") != null)

{

param1 = (String)qps.get("param1");

}

if (event.get("queryStringParameters") != null)

{

JSONObject qps = (JSONObject)event.get("queryStringParameters");

if ( qps.get("param2") != null)

{

param2 = (String)qps.get("param2");

}

catch(Exception pex)

{

responseJson.put("statusCode", "400");

responseJson.put("exception", pex);

}

// Implement your logic here

int output = 0;

if (proxy.equals("sum"))

{

output = sum(Integer.parseInt(param1), Integer.parseInt(param2));

}

else if (proxy.equals("subtract"))

{

output = subtract(Integer.parseInt(param1), Integer.parseInt(param2));

}

JSONObject responseBody = new JSONObject();

responseBody.put("input", event.toJSONString());

responseBody.put("message", "Output is" + output);

JSONObject headerJson = new JSONObject();

headerJson.put("x-custom-header", "my custom header value");

headerJson.put("Access-Control-Allow-Origin", "*");

responseJson.put("isBase64Encoded", false);

responseJson.put("statusCode", responseCode);

responseJson.put("headers", headerJson);

responseJson.put("body", responseBody.toString());

OutputStreamWriter writer = new OutputStreamWriter(outputStream, "UTF-8");

writer.write(responseJson.toJSONString());

writer.close();

}

public int sum(int a, int b)

{

return a+b;

}

public int subtract(int a, int b)

{

return a-b;

}

（左右滑动可查看全部代码）

白小白：

首先是代码中的类名，需要修改为第2步中的Class name，。其次是可能会遇到JSON无法解析的错误。需要下载JSON的包然后引入项目。引入的方法是将JSON包下载到本地，然后在项目上右键 –> Build Path –> Add External Achives 选择本地包添加即可。JSON包的下载地址（http://www.java2s.com/Code/JarDownload/json-simple/json-simple-1.1.jar.zip）。如果遇到 Fatal error compiling: tools.jar not found 的报错，从Eclipse菜单中选择 Windows -> Preferences -> Java -> Installed JREs –> Execution Environment -> JavaSE1.x -> JDE 1.x 勾选即可。至于那个.x，我选择的是最低版本号1.6

4. 构建并部署此Lambda函数。有关部署Java Lambda函数的完整信息可以找到这里

(https://docs.aws.amazon.com/lambda/latest/dg/java-create-jar-pkg-maven-and-eclipse.html).

白小白：

构建部署的方法其实很简单，就是在项目上右键 –> Amazon Web Services –> Upload function to AWS Lambda。但是前提是你需要有一个AWS的账号，并需要提供给Eclipse客户端一个Access Key ID和Secret Access Key。这需要你在AWS的控制台创建一个用户，并为用户添加 AdministratorAccess 权限，创建过程中可得到这两个值。但要及时保存，否则在创建后，Secret Access Key是不可见的，除非在安全证书页面重新创建访问密钥。上传函数的过程，可能会有部分输入框提示not found，此时只需要点击其右侧的create即可。

在这个例子中，我们用“REST_API_HelloWorld”的名称在AWS控制台中创建了Lambda函数。

步骤2：（环境：AWS控制台/网页）创建API网关端点

1.转到AWS控制台并启动API-网关服务。

2.点击“创建API”。

3.选择“新API”并提供“API名称”

4.在创建API之后，添加一个资源，如下所示：

a3169d3bbd495484c6503be3bf5d19ff15441880

5. 确保勾选“配置为代理资源”选项。

在下一个显示“Any”方法设置的屏幕上，选择“Lambda Function”作为集成类型。同时选中“Use Lambda Proxy integration”。选择部署Lambda函数的区域，并输入Lambda名称。

白小白：上面的Lambda Function输入框，可以输入刚才上传的函数名称，会出现下拉列表选择。在下一个部署API的步骤前，其实已经可以测试API是否可以正常工作，即点击资源 - ANY 再点击测试，方法选择GET ，在路径处输入 sum ，在查询字串处输入 param1=100&param2=100 ，点击测试，在右侧的响应正文部分，message的值应该为 "Output is 200"。如果很不幸，测试不成功，右侧显示的错误是：Malformed Lambda proxy response （正如第一次部署时小白所遇到的情况），可以尝试以下方法：1、确认第4步中的Enable API Gateway CORS是否已经勾选。；2、在代码中注释掉 headerJson.put("Access-Control-Allow-Origin", "*"); 这句话。

6.现在，我们将把这个API部署到一个暂存环境中。为此，单击“Action”并选择“Deploy API”。

19cfdfb1e0361f4564f913afb6631cf603002e8c

7.选择[NewStage]并提供一个staging名称和描述。在本教程中，我们使用“Dev”作为名称。一旦部署完成，控制台将带您到staging页。

8.复制“Invoke URL”，并在其上添加代理资源名称和参数，其中包含要发送给Lambda的值。有关本教程，请参阅下面的示例：

● 格式：https：//5yv20hbz44.execute-api.eu-west-1.amazonaws.com/Dev/{proxy}？{set_of_params_separated_by_&}
● 示例：https：//5yv20hbz44.execute-api.eu-west-1.amazonaws.com/Dev/sum?param1=100&param2=100

输出如下：

f45f1d9de6c14ce8362f2f29631107f3334deac7