主页 / coding / 问题 / 78908102
Accepted
Jeff
Asked: 2024-08-24 12:06:20 +0800 CST

如何从字节数组在 javafx 中创建 Media 对象？

  • 772

我正在尝试使用 MediaView、MediaPlayer 和 Media 在 javafx 中播放媒体。Media 类似乎只接受 URL 源来创建媒体（用于传递给 MediaPlayer）。我想传递缓存的字节数组来创建媒体对象。这支持吗？

我能够使用 URL 和文件播放媒体，但不能使用字节数组播放。

javafx

2 个回答

  1. Best Answer

    来自媒体文档“仅支持 HTTP、HTTPS、FILE 和 JAR URI。”。因此，您需要从使用其中一种协议的提供商处获取字节。

    您可以运行嵌入式 http 服务器并使用 http 协议提供该服务器的字节。

    或者您可以使用内存文件系统，使用文件或 jar 协议提供字节。

    示例嵌入式 http 服务器从内存中的字节提供内容。

    该示例提供图像 MIME 类型，但只要输入流正确（例如，代表正确编码的 mp3 或 mp4 数据），为媒体提供其他内容类型也可以。

    • 1

  2. 最简单的选择是将字节写入文件，然后将fileURI 传递给Media构造函数。

    public Media toMediaFile(byte[] bytes, String extension) throws IOException {
  Objects.requireNonNull(bytes);
  if (extension.isBlank())
    throw new IllegalArgumentException("blank extension");
  var file = Files.createTempFile("jfxmedia", "." + extension);
  Files.write(file, bytes, StandardOpenOption.WRITE);
  return new Media(file.toUri().toString());
}

    但是，如果您想将媒体的字节保留在内存中，那么我认为最简单的解决方案将是jewelsea 的答案中的建议之一：创建一个嵌入式服务器以通过 HTTP 提供媒体。您可以使用模块来实现这一点。另一个 jewelsea 答案jdk.httpserver中给出了使用该模块的示例（链接到他们对这个问题的回答）。但这是另一个更适合您用例的示例。

    服务器代码

    请注意，此示例服务器未实现处理RangeHTTP 标头的功能。我相信 JavaFX 媒体实现将使用该标头，至少在某些情况下如此。您可能希望在服务器中实现该功能。

    此外，找到功能更丰富的 HTTP 服务器库并将其作为依赖项添加到项目中可能比使用模块更容易。尽管后者对于仅用于在本地主机上通过 HTTP 提供数组jdk.httpserver服务的简单、基本服务器来说已经足够了。byte[]

    内存媒体.java

    package com.example;

public record InMemoryMedia(byte[] bytes, String contentType) {
   
  public int contentLength() {
    return bytes.length;
  }
}

    内存媒体服务器.java

    package com.example;

import com.sun.net.httpserver.HttpContext;
import com.sun.net.httpserver.HttpServer;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Objects;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicBoolean;

public class InMemoryMediaServer implements AutoCloseable {

  private final HttpServer httpServer;

  public InMemoryMediaServer(int port) throws IOException {
    var address = new InetSocketAddress(InetAddress.getLoopbackAddress(), port);
    httpServer = HttpServer.create(address, 1);
    httpServer.setExecutor(Executors.newVirtualThreadPerTaskExecutor());
    httpServer.start();
  }

  public RegistrationKey registerMedia(String path, InMemoryMedia media) {
    Objects.requireNonNull(path);
    Objects.requireNonNull(media);

    var context = httpServer.createContext(path, new InMemoryMediaHandler(media));
    return new RegistrationKey(context);
  }

  @Override
  public void close() {
    httpServer.stop(0);
  }

  public class RegistrationKey {

    private final AtomicBoolean unregistered = new AtomicBoolean();
    private final HttpContext context;

    RegistrationKey(HttpContext context) {
      this.context = context;
    }

    public URI uri() {
      var addr = httpServer.getAddress();

      var scheme = "http";
      var host = addr.getAddress().getHostAddress();
      int port = addr.getPort();
      var path = path();

      try {
        return new URI(scheme, null, host, port, path, null, null);
      } catch (URISyntaxException ex) {
        throw new IllegalArgumentException(ex);
      }
    }

    public String path() {
      return context.getPath();
    }

    public void unregister() {
      if (unregistered.compareAndSet(false, true)) {
        httpServer.removeContext(context);
      }
    }
  }
}

    内存媒体处理程序.java

    package com.example;

import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import java.io.IOException;

final class InMemoryMediaHandler implements HttpHandler {

  private final InMemoryMedia media;

  InMemoryMediaHandler(InMemoryMedia media) {
    this.media = media;
  }

  @Override
  public void handle(HttpExchange exchange) throws IOException {
    switch (exchange.getRequestMethod()) {
      case "HEAD" -> {
        setResponseHeaders(exchange.getResponseHeaders());
        exchange.sendResponseHeaders(200, -1);
      }
      case "GET" -> {
        setResponseHeaders(exchange.getResponseHeaders());
        exchange.sendResponseHeaders(200, media.contentLength());
        try (var out = exchange.getResponseBody()) {
          out.write(media.bytes());
        }
      }
      default -> exchange.sendResponseHeaders(405, -1);
    }
  }

  private void setResponseHeaders(Headers headers) {
    headers.set("Accept-Ranges", "none");
    headers.set("Content-Type", media.contentType());
    headers.set("Content-Length", Integer.toString(media.contentLength()));
  }
}

    应用程序代码

    一些代码展示了如何使用该类InMemoryMediaServer。

    主程序

    package com.example;

import javafx.application.Application;
import javafx.scene.Scene;
import javafx.scene.layout.StackPane;
import javafx.scene.media.Media;
import javafx.scene.media.MediaPlayer;
import javafx.scene.media.MediaView;
import javafx.stage.Stage;

public class Main extends Application {

  private InMemoryMediaServer server;
  private String mediaUri;

  @Override
  public void init() throws Exception {
    server = new InMemoryMediaServer(8888);

    var key = server.registerMedia("/test", getInMemoryMedia());
    mediaUri = key.uri().toString();
  }

  private InMemoryMedia getInMemoryMedia() {
    throw new UnsupportedOperationException("not implemented"); // TODO: Implement
  }

  @Override
  public void start(Stage primaryStage) {
    var media = new Media(mediaUri);
    media.setOnError(() -> media.getError().printStackTrace());

    var player = new MediaPlayer(media);
    player.setAutoPlay(true);

    primaryStage.setScene(new Scene(new StackPane(new MediaView(player))));
    primaryStage.show();
  }

  @Override
  public void stop() {
    server.close();
  }
}
    • 0

相关问题