Interagieren Sie mit der LINE Message API mit Lambda (Java)

Service verwendet

• AWS API Gateway
• AWS Lambda
• LINE Message API

Entwicklungsumgebung usw.

• Java 1.8
• Eclipse
• Maven

Zweck

• Ich möchte wissen, wie ich mit der Line Message API kommunizieren kann
• Ich möchte wissen, wie man AWS Lambda benutzt.

Was in diesem Artikel weggelassen wird

• Eröffnung eines LINE-Kontos und Festlegen einer Webhook-URL

• So richten Sie das API-Gateway ein

• Ein Mechanismus zum Festlegen der "Server IP Whitelist" auf der Line Message API-Seite und zum Authentifizieren auch auf der AWS-Seite

• Unterschreiben Sie die Bestätigung, um zu bestätigen, dass die Anfrage von LINE gesendet wird

• Mechanismus zum Abrufen des von Line festgelegten Channel Access Token von der Lambda-Umgebungsvariablen

Verfahren

1. LINE Message API

2. Eröffnen Sie ein Konto

3. Webhook-URL-Einstellung

4. AWS API Gateway

5. Ressourcenerstellung

6. Verknüpfen Sie die erstellte Ressource mit der Lambda-Funktion

7. Lambda Function

3.1 Erstellen Sie eine Eingabeklasse, um JSON von POJO zu empfangen 3.2. Ausgabeklasse erstellen 3.3. ReplyToken und Text von Input abrufen und in Output speichern. Außerdem werden die für die Antwortnachricht erforderlichen Informationen festgelegt. 3.4. Konvertieren Sie die Ausgabe in JSON 3.5 Generieren und senden Sie eine Anfrage 3.6. Ganzer Code

3.1 Erstellen Sie eine Eingabeklasse, um JSON von POJO zu empfangen

Das folgende JSON-Objekt wird gesendet. Erstellen Sie daher die Eingabeklasse entsprechend.

{
  "events": [
    {
      "replyToken": "nHuyWiB7yP5Zw52FIkcQobQuGDXCTA",
      "type": "message",
      "timestamp": 1462629479859,
      "source": {
        "type": "user",
        "userId": "U206d25c2ea6bd87c17655609a1c37cb8"
      },
      "message": {
        "id": "325708",
        "type": "text",
        "text": "Hello, world"
      }
    },
    {
      "replyToken": "nHuyWiB7yP5Zw52FIkcQobQuGDXCTA",
      "type": "follow",
      "timestamp": 1462629479859,
      "source": {
        "type": "user",
        "userId": "U206d25c2ea6bd87c17655609a1c37cb8"
      }
    }
  ]
}

Input.java

package jp.linebot;

import java.util.List;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Input {
	
	private Events[] events;
	
}

Events.java

package jp.linebot;

import org.joda.time.DateTime;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Events {
	private String replyToken;
	private String type;
	private Long timestamp;
	private Source source;
	private Message message;	
}

Source.java

package jp.linebot;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Source {
	private String type;
	private String userId;
}

Message.java

package jp.linebot;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Message {
	private String id;
	private String type;
	private String text;	
}

3.2. Ausgabeklasse erstellen

Output.java

package jp.linebot;

import java.util.ArrayList;
import java.util.List;

import lombok.Data;

@Data
public class Output {

	private String replyToken;
	private List<Messages> messages = new ArrayList<>();
}

Messages.java

package jp.linebot;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Messages {

	private String type;
	private String text;
}

3.3. ReplyToken und Text von Input abrufen und in Output speichern. Außerdem werden die für die Antwortnachricht erforderlichen Informationen festgelegt.

Output output = new Output();
output.setReplyToken(input.getEvents()[0].getReplyToken());
Messages outMessage = new Messages();
outMessage.setType("text");
outMessage.setText(input.getEvents()[0].getMessage().getText() + "?");
output.getMessages().add(outMessage);

3.4. Konvertieren Sie die Ausgabe in JSON

Gson gson = new Gson();
context.getLogger().log(gson.toJson(output));

3.5 Generieren und senden Sie eine Anfrage

httpPost = new HttpPost("https://api.line.me/v2/bot/message/reply");
httpPost.setHeader("Content-Type", "application/json");
httpPost.setHeader("Authorization", "Bearer " + "{Channel Access Token}");
StringEntity entity = new StringEntity(gson.toJson(output), StandardCharsets.UTF_8);
httpPost.setEntity(entity);

try (CloseableHttpClient client = HttpClients.createDefault();
     CloseableHttpResponse resp = client.execute(httpPost);
     BufferedReader br = new BufferedReader(new InputStreamReader(resp.getEntity().getContent(), StandardCharsets.UTF_8)))
{
        int statusCode = resp.getStatusLine().getStatusCode();
        switch (statusCode) {
        case 200:
            br.readLine();
            break;
        default:
        }
    } catch (final ClientProtocolException e) {
    } catch (final IOException e) {
}
return null;

3.6. Ganzer Code

LambdaFunctionHandler.java

package jp.linebot;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;

import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.google.gson.Gson;

public class LambdaFunctionHandler implements RequestHandler<Input, Object> {

	@Override
	public Object handleRequest(Input input, Context context) {
		// TODO Auto-generated method stub

		context.getLogger().log("token : " + input.getEvents()[0].getReplyToken());
		context.getLogger().log("text : " + input.getEvents()[0].getMessage().getText());
		
		Output output = new Output();
		output.setReplyToken(input.getEvents()[0].getReplyToken());
		Messages outMessage = new Messages();
		outMessage.setType("text");
		outMessage.setText(input.getEvents()[0].getMessage().getText() + "?");
		output.getMessages().add(outMessage);

		HttpPost httpPost = new HttpPost("https://api.line.me/v2/bot/message/reply");
		httpPost.setHeader("Content-Type", "application/json");
		httpPost.setHeader("Authorization", "Bearer " + "{Channel Access Token}");

		Gson gson = new Gson();
		context.getLogger().log(gson.toJson(output));
		StringEntity entity = new StringEntity(gson.toJson(output), StandardCharsets.UTF_8);
		httpPost.setEntity(entity);
		try (CloseableHttpClient client = HttpClients.createDefault();
                CloseableHttpResponse resp = client.execute(httpPost);
                BufferedReader br = new BufferedReader(new InputStreamReader(resp.getEntity().getContent(), StandardCharsets.UTF_8)))
        {
            int statusCode = resp.getStatusLine().getStatusCode();
            switch (statusCode) {
            case 200:
                br.readLine();
                break;
            default:
            }
        } catch (final ClientProtocolException e) {
        } catch (final IOException e) {
        }
		return null;
	}
	
}

Referenzlink

• Line Message API
• Jackson speichert JSON-Daten in POJO
• [Java] Eine schnelle Implementierung der Messaging-API von LINE mit einem Servlet eröffnete die Zukunft