第一次提交

Author: KotlinAmai

README.md

@@ -0,0 +1,37 @@
+# DanMaKu-Engine
+## 说明
+```
+  这是一个屏幕弹幕引擎,主要作用是在屏幕中发送弹幕.
+  运用场景:比如说年会,活动... 需要在屏幕中发送弹幕的场景
+```
+
+## 使用方法
+
+[DanMaKu-Engine](https://github.com/actar676309180/DanMaKu-Engine/releases/)
+
+1. 点击上方链接,下载jar文件  
+2. 在你的项目中引入jar文件
+3.
+```
+    DanMaKuEngine.open()
+    val danMaKu = DanMaKu("This is a Test.", Font.font(22.0), Color.GREEN)
+    DanMaKuEngine.launch(danMaKu)
+```
+
+本项目基于JavaFX,需要jdk1.8及以上
+如果使用的是openjdk,则需要引入openjfx
+
+```
+DanMaKuEngine.open()
+```
+用于打开一个窗口,此方法是阻塞的.耗时2-3秒.
+
+```
+DanMaKu("This is a Test.", Font.font(22.0), Color.GREEN)
+```
+用于创建一个弹幕 DanMaKu("消息",字体,颜色)
+
+```
+DanMaKuEngine.launch(danMaKu)
+```
+用于发送弹幕

pom.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.github.actar676309180</groupId>
+    <artifactId>DanMaKu-Engine</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+
+</project>

src/main/java/com/github/actar676309180/danmaku/Bullet.java

@@ -0,0 +1,28 @@
+package com.github.actar676309180.danmaku;
+
+import com.github.actar676309180.danmaku.utils.ScreenUtil;
+import javafx.scene.layout.VBox;
+import javafx.scene.text.Text;
+
+import java.util.Random;
+
+
+public class Bullet extends VBox {
+
+    private static Random random = new Random();
+
+    public Bullet(DanMaKu danMaKu){
+        Text text = new Text(danMaKu.getMessage());
+        text.setFont(danMaKu.getFont());
+        text.setFill(danMaKu.getColor());
+        this.getChildren().add(text);
+        this.setStyle("-fx-background:transparent;");
+
+        double width = ScreenUtil.visualBoundWidth;
+        double height = ScreenUtil.visualBoundHeight;
+
+        this.setTranslateX(width);
+
+        this.setTranslateY(random.nextInt((int)height));
+    }
+}

src/main/java/com/github/actar676309180/danmaku/DanMaKu.java

@@ -0,0 +1,49 @@
+package com.github.actar676309180.danmaku;
+
+import javafx.scene.paint.Color;
+import javafx.scene.text.Font;
+
+public class DanMaKu {
+    private String message;
+    private Font font;
+    private Color color;
+
+    public DanMaKu(String message, Font font, Color color) {
+        this.message = message;
+        this.font = font;
+        this.color = color;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public Font getFont() {
+        return font;
+    }
+
+    public void setFont(Font font) {
+        this.font = font;
+    }
+
+    public Color getColor() {
+        return color;
+    }
+
+    public void setColor(Color color) {
+        this.color = color;
+    }
+
+    @Override
+    public String toString() {
+        return "DanMaKu{" +
+                "message='" + message + '\'' +
+                ", font=" + font +
+                ", color=" + color +
+                '}';
+    }
+}

src/main/java/com/github/actar676309180/danmaku/DanMaKuEngine.java

@@ -0,0 +1,41 @@
+package com.github.actar676309180.danmaku;
+
+import javafx.application.Application;
+
+class DanMaKuEngine {
+
+    private static boolean isOpen = false;
+
+    static DanMaKuView danMaKudanMaKuView = null;
+
+    /**
+     * 打开弹幕引擎
+     */
+    static synchronized void open() {
+        if (!isOpen) {
+            new Thread(() -> Application.launch(DanMaKuView.class)).start();
+            try {
+                while (danMaKudanMaKuView == null) Thread.sleep(10);
+            } catch (InterruptedException e) {
+                throw new RuntimeException("线程调度失败");
+            }
+            isOpen = true;
+        } else {
+            throw new RuntimeException("open 不能被调用两次");
+        }
+    }
+
+    /**
+     * 发射弹幕
+     *
+     * @param danMaKu 弹幕
+     */
+    public static void launch(DanMaKu danMaKu) {
+        if (isOpen) {
+            danMaKudanMaKuView.launch(danMaKu);
+        } else {
+            throw new RuntimeException("未初始化,无法发射弹幕");
+        }
+    }
+
+}

src/main/java/com/github/actar676309180/danmaku/DanMaKuView.java

@@ -0,0 +1,111 @@
+package com.github.actar676309180.danmaku;
+
+import com.github.actar676309180.danmaku.utils.ScreenUtil;
+import javafx.application.Application;
+import javafx.application.Platform;
+import javafx.scene.Scene;
+import javafx.scene.layout.StackPane;
+import javafx.stage.Stage;
+import javafx.stage.StageStyle;
+
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class DanMaKuView extends Application implements Runnable {
+
+    private Lock lock = new ReentrantLock();
+
+    private StackPane root = new StackPane();
+    private List<Bullet> readyList = new CopyOnWriteArrayList<>();
+    private List<Bullet> loopList = new CopyOnWriteArrayList<>();
+    private List<Bullet> destroyList = new CopyOnWriteArrayList<>();
+
+    @Override
+    public void start(Stage primaryStage) {
+        DanMaKuEngine.danMaKudanMaKuView = this;
+
+        double width = ScreenUtil.visualBoundWidth;
+        double height = ScreenUtil.visualBoundHeight;
+
+        Scene scene = new Scene(root, width, height);
+
+        scene.setFill(null);
+
+        primaryStage.initStyle(StageStyle.TRANSPARENT);
+
+        primaryStage.setWidth(width);
+        primaryStage.setHeight(height);
+        primaryStage.setX(0);
+        primaryStage.setY(0);
+
+        primaryStage.setTitle("Dan Ma Ku");
+        primaryStage.setScene(scene);
+        // 始终悬浮在顶层
+        primaryStage.setAlwaysOnTop(true);
+        primaryStage.show();
+        new Thread(this).start();
+    }
+
+    private void ready() {
+        lock.lock();
+        try {
+            for (Bullet bullet : readyList) {
+                loopList.add(bullet);
+                Platform.runLater(() -> {
+                    root.getChildren().add(bullet);
+                });
+            }
+            readyList.clear();
+        } finally {
+            lock.unlock();
+        }
+    }
+
+    private void loop() {
+        for (Bullet bullet : loopList) {
+            Platform.runLater(()->{
+                bullet.setTranslateX(bullet.getTranslateX()-1);
+            });
+            if (bullet.getTranslateX() <  0){
+                destroyList.add(bullet);
+            }
+        }
+    }
+
+    private void destroy() {
+        for (Bullet bullet : destroyList) {
+            loopList.remove(bullet);
+            Platform.runLater(()->{
+                root.getChildren().remove(bullet);
+            });
+        }
+        destroyList.clear();
+    }
+
+    @Override
+    public void run() {
+        while (true) {
+            try { Thread.sleep(10); } catch (InterruptedException e) {e.printStackTrace();}
+            ready();
+            loop();
+            destroy();
+        }
+    }
+
+    /**
+     * 发射弹幕
+     *
+     * @param danMaKu 弹幕
+     */
+    public void launch(DanMaKu danMaKu) {
+        lock.lock();
+        try {
+            Bullet bullet = new Bullet(danMaKu);
+            readyList.add(bullet);
+        } finally {
+            lock.unlock();
+        }
+    }
+}

src/main/java/com/github/actar676309180/danmaku/utils/ScreenUtil.java

@@ -0,0 +1,23 @@
+package com.github.actar676309180.danmaku.utils;
+
+import javafx.geometry.Rectangle2D;
+import javafx.stage.Screen;
+
+public class ScreenUtil {
+
+    public final static Double boundWidth;
+    public final static Double boundHeight;
+    public final static Double visualBoundWidth;
+    public final static Double visualBoundHeight;
+
+    static {
+        final Screen primary = Screen.getPrimary();
+        final Rectangle2D bounds = primary.getBounds();
+        boundWidth = bounds.getWidth();
+        boundHeight = bounds.getHeight();
+        final Rectangle2D visualBounds = primary.getVisualBounds();
+        visualBoundWidth = visualBounds.getWidth();
+        visualBoundHeight = visualBounds.getHeight();
+    }
+
+}

src/test/java/com/github/actar676309180/danmaku/MainTest.java

@@ -0,0 +1,14 @@
+package com.github.actar676309180.danmaku;
+
+import javafx.scene.paint.Color;
+import javafx.scene.text.Font;
+
+public class MainTest {
+    public static void main(String[] args) throws InterruptedException {
+        DanMaKuEngine.open();
+        for (int i = 0; i < 10000; i++) {
+            Thread.sleep(500);
+            DanMaKuEngine.launch(new DanMaKu("test "+i,Font.font(40), Color.GREEN));
+        }
+    }
+}