Interagir avec l'API de message LINE à l'aide de Lambda (Java)

Service utilisé

• AWS API Gateway
• AWS Lambda
• LINE Message API

Environnement de développement, etc.

• Java 1.8
• Eclipse
• Maven

Objectif

• Je veux savoir comment parler à l'API de message de ligne
• Je souhaite savoir comment utiliser AWS Lambda.

Ce qui est omis dans cet article

• Ouverture d'un compte LINE et définition d'une URL Webhook

• Comment configurer API Gateway

• Un mécanisme pour définir "Server IP Whitelist" du côté API de message de ligne et s'authentifier du côté AWS également

• Signez la vérification pour confirmer que la demande est envoyée depuis LINE

• Mécanisme pour obtenir un jeton d'accès au canal défini par ligne à partir de la variable d'environnement Lambda

procédure

1. LINE Message API

2. Ouvrez un compte

3. Paramètre d'URL du Webhook

4. AWS API Gateway

5. Création de ressources

6. Liez la ressource créée à la fonction Lambda

7. Lambda Function

3.1. Créer une classe d'entrée pour recevoir JSON par POJO 3.2. Créer une classe de sortie 3.3 Récupérer le jeton de réponse et le texte de Input et stocker dans Output. En outre, les informations requises pour le message de réponse sont également définies. 3.4. Convertir la sortie en JSON 3.5. Générer et envoyer une demande 3.6. Code entier

3.1. Créer une classe d'entrée pour recevoir JSON par POJO

L'objet JSON suivant sera envoyé, créez donc la classe Input en conséquence.

{
  "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. Créer une classe de sortie

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 Récupérer le jeton de réponse et le texte de Input et stocker dans Output. En outre, les informations requises pour le message de réponse sont également définies.

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. Convertir la sortie en JSON

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

3.5. Générer et envoyer une demande

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. Code entier

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;
	}
	
}

Lien de référence

• Line Message API
• Jackson stocke les données JSON dans POJO
• [Java] Une implémentation rapide de l'API Messaging de LINE avec un servlet a ouvert le futur