注意

FFIを初めて使ってみたネタレベルなので本番でやってはいけません。
threadの処理がかなりまずい気がします
helixやruruは使っていません。使ってみたいです。
.trb形式でのinline rustも使ってないです。

モチベーション

今年の9月から新しい会社に転職し、 railsを使い始めました。
その前はjava書いていたので、嬉しさ反面、並列処理まわりで少し不満もあります。
rubyを書き出してGiant VM Lockという言葉を初めて知ったのですが、rubyのthreadって実際はIO系の処理しか並列で動かせないので、なんとも…

たとえばcontrollerでなにか処理をしたあと、httpレスポンスを先に返して、バックグラウンド処理でメールやslackに処理を飛ばす処理は簡単には書けません。
やるとしたらdelayed jobやsidekiq等を使うことになると思います。

現状それが現実解だと思いますが、sidekiqなどを使うなら、

sidekiqプロセスの監視機構を用意

といった作業が必要です。cron等で定時バッチでやるコードを書くという手段はもっとだるいです。

それぐらいやれよというのは、そのとおりなのですが、
ようは軽い気持ちでバックグラウンド処理やりたいですよね！

ということでcontrollerで処理を飛ばしたあと、（軽い気持ちで??）rustコードを書いてslack通知をやってみたいとおもいます。

rust側

railsのルートディレクトリ直下にに rust/ というディレクトリを切ってその中で

$ cargo new afterslack

しました。これで rust/afterslack/ というディレクトリができます。
afetslackというのがrust側のプロジェクト名です。
(ネーミングおかしいのは見逃してください…)

rust側でslackに通知してみます。
slack-hook というクレート(rustのライブラリの呼び方)を使いました。
確認しやすいように3秒まつコードにしました。

extern crate slack_hook;
use slack_hook::{Slack, PayloadBuilder};
use std::time::Duration;
use std::thread;

#[no_mangle]
pub extern fn send_msg_ffi() {
    thread::spawn(move || {
        send_msg();
    });
}

fn send_msg() {
    println!("rust-slack-start");
    let webhook_url = "<自分のslackのwebhook url>";

    let slack = Slack::new(webhook_url).unwrap();
    let p = PayloadBuilder::new()
        .text("rustrustrust")
        .channel("<#ではじまるチャンネル名 or @ではじまる宛先ユーザー名>")
        .username("rust-slack-notify")
        .build()
        .unwrap();

    let res = slack.send(&p);
    match res {
        Ok(()) => println!("ok"),
        Err(e) => println!("ERR: {:?}", e)
    }
	
	// あえて3秒まってみる
    thread::sleep(Duration::from_millis(3000));
    println!("rust-slack-end");
}

Cargo.tomlはこんなかんじです。

[package]
name = "afterslack"
version = "0.1.0"
authors = ["なまえ <めあど>"]

[lib]
name = "afterslackffi"
crate-type = ["dylib"]

[dependencies]
slack-hook = "0.2"

でbuildします。

$ cargo build --release

成果物はrailsのルートディレクトリからみると
rust/afterslack/target/release/libafterslackffi.dylib
というところにできあがります。

rails側

rails new はもうやっている前提なので
controller作りましょう

class PostsController < ActionController::Base
  # POST /posts
  def create
    render text: ':create' # ここDEPRECATION WARNINGなの見逃してください
    AfterSlack.send_msg_ffi
  end
end

AfterSlack.send_msg_ffiってというのがafterslackを呼び出しているruby側コードです。これも自分で書きました。次の通りです。

module AfterSlack
  extend FFI::Library

  ffi_lib Rails.root.join 'rust/afterslack/target/release/libafterslackffi.dylib'

  attach_function :send_msg_ffi, [], :void, blocking: false
end

リクエストなげてみる

まずはthread使わないでやると

...

#[no_mangle]
pub extern fn send_msg_ffi() {
    // ためしにさっきのコードをスレッド使わずにやる
    // thread::spawn(move || {
        send_msg();
    // }); 
}

...

結果
curl -XPOST localhost:3000/postsをやってみるとrailsサーバーのログにこんな結果がでました。

Completed 200 OK in 3347ms (Views: 6.2ms | ActiveRecord: 0.0ms)

Threadの中でやってみる

threadを使うようにして、再度、cargo build –releaseしてcurlを叩いてみます。

結果

Completed 200 OK in 25ms (Views: 5.4ms | ActiveRecord: 0.0ms)

うぇーい！！　3347 ms -> 25 ms
slackにもちゃんととんでいました。

#再度注意

すいません。これうぇーいとよろこんでいますが
joinしていないthread処理をFFI経由で実行した場合、後処理はどうするんだ？
たぶん、いけないものが残る….気が..

まとめ

FFIやrustのthread処理については詳しく把握する必要がありますが、
ノウハウがたまれば、sidekiq等を用意するよりも気軽にバックグラウンド処理ができます。
本当に必要なビジネスロジックだけ実行したら、さっさとユーザーにレスポンスを返して、他の処理は後でやりたいです！

明日は

あしたはjoker1007さんです。個人的な面識などはありませんが、常日頃名前はお見かけします。
投稿タイトルも気になります。期待しています。