承前

• ブラウザ->ウェブアプリ->ActiveMQ->ApacheCamel->AWS S3 と言うルートを考えてみましょう。
  • ウェブアプリでEXIF情報を消去したり、画像縮小を行ってS3にアップロードするには、少々重たい処理ですね。
    • 非同期で、イベント駆動で処理したいですよね。
  • ウェブアプリはDockerで建てているのだから、ActiveMQ¹ も Consumerである Apache Camel² もDockerでインスタンス作って、メッセージ送信/受信したらいいよね。
  • …と、思ったら、意外と大変だった、と言う感じです。

JMS(Java Message Service) と Producer と Consumer

• JMSは歴史的経緯から、とにかく複雑な仕様で、正直に向き合うと、げんなりしてしまうのですけどね…。
• まぁ、シンプルにProducer->ActiveMQ->Consumerで、送信元Producerが、受信元Consumerに向けて、オブジェクトをメッセージとして送る、オブジェクトのエンコード/デコードを簡単に(？)やってくれる、と、考えたら良いと思います。
  • 今回はウェブアプリがProducerの役割ですね。

ウェブアプリケーションに画像アップロード

• 結局、ファイル名と拡張子を文字列で取れて、画像のデータをbyte[]か、InputStreamで取れれば良いと思います。
  • マルチパートでのRESTクライアントの使用 - Quarkus
    • 依存関係に Quarkus RESTEasy Multipart Runtimeを忘れずに。

画像データをActiveMQに送信する

• JMSの使用 - Quarkus
  • 依存関係に Quarkus Artemis JMS Runtimeを忘れずに。
  • application.propertiesにquarkus.artemis.***=を記述することを忘れないように。
  • そうすると、ConnectionFactoryもDI対象になりますよ。

  public void uploadImage(String fileName, InputStream file) {
    try (JMSContext context = this.connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE);
        ByteArrayOutputStream out = new ByteArrayOutputStream()) {
      // ファイル読み込み
      file.transferTo(out);
      out.flush();

      // メッセージ作成
      BytesMessage message = context.createBytesMessage();
      message.setStringProperty("fileName", fileName);
      message.writeBytes(out.toByteArray());
      
      // トピックを送信
      context.createProducer().send(context.createTopic("upload.image"), message);
    } catch (IOException | JMSException e) {
      throw new RuntimeException(e);
    }
  }