带有 netty 的音频流服务器答案

【问题标题】：audio stream server with netty带有 netty 的音频流服务器
【发布时间】：2014-02-25 05:42:35
【问题描述】：

我正在尝试创建一个简单的音频流服务器，如概念证明，但我遇到了一些困难。我正在流式传输单个文件开始，我搜索但没有找到足够的信息来创建音频流服务器，所以我只是根据我对服务器的了解创建了一个简单的服务器。我使用 netty 创建了它，将流传递给 ChunkedStream 对象并将其写入通道：

public class CastServerHandler extends SimpleChannelHandler {

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
        throws Exception {
    HttpRequest request = (HttpRequest) e.getMessage();
    if (request.getMethod() != GET) {
        sendError(ctx, METHOD_NOT_ALLOWED);
        return;
    }

    HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
    System.out.println(response.toString());
    Channel channel = e.getChannel();
    channel.write(response);
    ChannelFuture writeFuture;
    StreamSource source = StreamSource.getInstance();
    ChunkedStream stream = new ChunkedStream(source.getLiveStream());
    writeFuture = channel.write(stream);
    writeFuture.addListener(new ChannelFutureProgressListener() {
        public void operationComplete(ChannelFuture future) {
            System.out.println("terminou");
            future.getChannel().close();
        }

        public void operationProgressed(ChannelFuture future, long amount,
                long current, long total) {
            System.out.println("Transferido: " + current + " de " + total);
        }
    });
    if (!isKeepAlive(request)) {            
        writeFuture.addListener(ChannelFutureListener.CLOSE);
    }
}

private void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {
    HttpResponse response = new DefaultHttpResponse(HTTP_1_1, status);
    response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
    response.setContent(ChannelBuffers.copiedBuffer(
            "Failure: " + status.toString() + "\r\n", CharsetUtil.UTF_8));

    // Close the connection as soon as the error message is sent.
    ctx.getChannel().write(response)
            .addListener(ChannelFutureListener.CLOSE);
}

private void writeLiveStream(Channel channel) {
    StreamSource source = StreamSource.getInstance();
    ChunkedStream stream = new ChunkedStream(source.getLiveStream());
    channel.write(stream);
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
        throws Exception {
    e.getCause().printStackTrace();
    e.getChannel().close();
}
}

幸运的是，我没有成功地将音频直接流式传输到网络浏览器，所以我试图弄清楚 icecast 作为对网络浏览器的响应返回什么，并在标题中返回这些属性：

缓存控制：无缓存
内容类型：应用程序/ogg
服务器：Icecast 2.3.2
冰音频信息：采样率=44100；频道=2；质量=3%2e00
冰冷的描述：流测试
冰冷类型：摇滚
冰冷的名称：Radio teste Brevleq
冰酒吧：0

netty 有没有一种简单的方法将这些内容放在 HttpResponse 标头中（特别是 Content-type:applicio/ogg）？我希望这是问题所在......

【问题讨论】：

唯一需要的标头是Content-Type。其他一切都只是额外的信息。

标签： java http streaming audio-streaming netty

【解决方案1】：

请参阅API of HttpResponse。它有 setHeader 方法。

【讨论】：

【解决方案2】：

我会考虑使用直接二进制协议，并仅为代理创建 HTTP 接口。没有理由为这样的事情处理基于文本的协议。

【讨论】：