2

我有一个 ServerResource 通过发回二进制数据来响应 GET 请求。问题是二进制数据的源将通过单独的 REST 调用（可能通过HttpAsyncClient）异步下载。是否可以创建一个表示，当它从异步下载到达时，我可以将数据提供给它？我需要能够在不阻塞任何线程的情况下做到这一点，因此需要某种 NIO 解决方案。

我怀疑我可以用WriteableRepresetation做到这一点，但我不确定文档所说的如何

为此，您只需要创建一个子类并覆盖抽象的 Representation.write(WritableByteChannel) 方法。当需要实际表示的内容时，连接器稍后将回调此方法。

暗示在调用该方法时，所有内容必须已经可用。

我正在使用 v2.1。

4

2 回答 2

1

在玩了一会儿之后，看起来这可以使用ReadableRepresentation。我不知道是否有比使用管道更好的方法来创建 ReadableByteChannel，但这是我看到的唯一方法，而不必实现我自己的 Channel。

private static final byte[] HELLO_WORLD = "hello world\n".getBytes(Charsets.UTF_8);

public static class HelloWorldResource extends ServerResource {
    @Get
    public Representation represent() throws Exception {
        final Pipe pipe = Pipe.open();

        // this simulates another process generating the data
        Thread t = new Thread(new Runnable() {
            private final ByteBuffer buf = ByteBuffer.allocate(1);
            private final Pipe.SinkChannel sink = pipe.sink();

            private int offset = 0;

            @Override
            public void run() {
                while (offset < HELLO_WORLD.length) {
                    try {
                        buf.clear();
                        buf.put(HELLO_WORLD[offset++]);
                        buf.flip();

                        while (buf.hasRemaining()) {
                            sink.write(buf);
                        }

                        Thread.sleep(500);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }

                try {
                    sink.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        });
        t.setDaemon(true);
        t.start();

        return new ReadableRepresentation(pipe.source(), MediaType.TEXT_PLAIN);
    }
}

public static class HelloWorldApplication extends Application {
    @Override
    public synchronized Restlet createInboundRoot() {
        Router router = new Router(getContext());
        router.attach("/hello", HelloWorldResource.class);

        return router;
    }
}

public static void main(String[] args) throws Exception {
    Component component = new Component();
    component.getDefaultHost().attach("", new HelloWorldApplication());

    Server server = component.getServers().add(Protocol.HTTP, 8090);

    component.start();
}
于 2012-10-18T23:19:33.150 回答
0

在玩弄了上述解决方案之后，我发现您可以像这样创建一个 ReadableByteChannel：

        ByteArrayInputStream stream = new ByteArrayInputStream(myByteArray);
        ReadableByteChannel channel = Channels.newChannel(stream);

不过，上面的答案很好，为我省去了很多麻烦。

于 2013-10-07T09:21:11.437 回答