FilesExpand file tree

master

/

MessageRouter.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

46 lines (39 loc) · 1.55 KB

master

/

MessageRouter.java

Copy path

Top

File metadata and controls

• Code
• Blame

46 lines (39 loc) · 1.55 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

package server;

import com.modulecode.net.IRequest;

import com.modulecode.net.impl.BaseRouter;

import com.modulecode.utils.JacksonUtils;

import lombok.SneakyThrows;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.apache.logging.log4j.core.util.Cancellable;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.net.MalformedURLException;

import java.net.URL;

import java.nio.charset.StandardCharsets;

import java.util.HashMap;

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.FutureTask;

public class MessageRouter extends BaseRouter {

private static final Logger logger = LogManager.getLogger(MessageRouter.class);

@SneakyThrows

@Override

public void handle(IRequest request) throws IOException {

String jsonData = request.getString("utf-8");

Message message = JacksonUtils.json2Bean(jsonData, Message.class);

System.out.println(message);

String webMessage = getWebMessage(message.getMessage());

logger.info(webMessage);

request.getConnection().sendMsg(0, webMessage.getBytes(StandardCharsets.UTF_8));

}

@SneakyThrows

public String getWebMessage(String message) {

var url = new URL("http://api.qingyunke.com/api.php?key=free&appid=0&msg=" + message);

InputStream is = url.openStream();

BufferedReader br = new BufferedReader(new InputStreamReader(is));

return br.readLine();

}

}