[Java记录]实时抓取斗鱼弹幕

[Java记录]实时抓取斗鱼弹幕

// 关键依赖 WebSocket客户端

org.java-websocket

Java-WebSocket

1.5.1

import org.java_websocket.client.WebSocketClient;

import org.java_websocket.handshake.ServerHandshake;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.net.URI;

import java.nio.ByteBuffer;

import java.nio.charset.StandardCharsets;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

/**

* 抓取斗鱼弹幕

*

* @author wind

* @date @s_2020/9/8

*/

public class DouYuBarrage {

/**

* wss://danmuproxy.douyu.com:8501/

* wss://danmuproxy.douyu.com:8502/

* wss://danmuproxy.douyu.com:8503/

* wss://danmuproxy.douyu.com:8504/

*/

private static final String BARRAGE_SERVER = "wss://danmuproxy.douyu.com:8501/";

private static final Pattern CONTENT_PATTERN = Pattern.compile("[email protected]=chatmsg.*?/[email protected]=(.*?)/[email protected]=(.*?)/[email protected]=(.*?)/.*?/[email protected]=(.*?)/");

public static void main(String[] args) throws Exception {

connect("99999");

}

/**

* 连接斗鱼弹幕服务器

*

* @author wind

* @date @s_2020/9/8

*/

public static void connect(String roomId) throws Exception {

new WebSocketClient(new URI(BARRAGE_SERVER), new Draft_6455()) {

@Override

public void onOpen(ServerHandshake serverHandshake) {

System.out.println("已连接");

this.send(login(roomId));

this.send(joinGroup(roomId));

new Thread(() -> {

while (true) {

this.send(keepLive());

System.err.println("发送心跳");

try {

Thread.sleep(40000);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}).start();

}

@Override

public void onMessage(String s) {

}

@Override

public void onMessage(ByteBuffer bytes) {

String result = new String(bytes.array(), StandardCharsets.UTF_8);

// 原数据

//System.out.println(result);

// 正则解析需要的数据并打印

analyzeAndPrintBarrage(result);

[Java记录]实时抓取斗鱼弹幕相关教程