2

バイナリデータを送り返すことでGETリクエストに応答するServerResourceがあります。問題は、バイナリデータのソースが別のREST呼び出しを介して（おそらくHttpAsyncClientを介して）非同期にダウンロードされることです。非同期ダウンロードから到着したデータをフィードできるリプレゼンテーションを作成することはできますか？スレッドをブロックせずに実行できる必要があるため、何らかのNIOソリューションが必要です。

WriteableRepresetationを使用してこれを実行できると思いますが、ドキュメントに記載されているとおり、正確にはわかりません。

このためには、サブクラスを作成し、抽象Representation.write（WritableByteChannel）メソッドをオーバーライドする必要があります。このメソッドは、実際の表現のコンテンツが必要になったときに、後でコネクタによってコールバックされます。

これは、メソッドが呼び出されたときに、すべてのコンテンツがすでに利用可能である必要があることを意味します。

私はv2.1を使用しています。

4

2 に答える 2

1

少し遊んだ後、ReadableRepresentationを使用してこれが可能であるように見えます。パイプを使用するよりもReadableByteChannelを作成するためのより良い方法があるかどうかはわかりませんが、それが自分のチャネルを実装せずに見た唯一の方法です。

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 に答える