マイクロサービスとは何か — 定義と原則

# モノリスのデプロイ
$ git push origin main
# → アプリ全体が再起動
# → 商品機能の修正でも、注文機能のコードも再デプロイされる
# → ダウンタイムリスクが全機能に影響
 
# マイクロサービスのデプロイ
$ git push product-service main
# → 商品サービスだけが再デプロイ
# → 注文サービスは影響なく動作し続ける
# → ダウンタイムリスクは商品機能のみ

# モノリスでの障害伝播（疑似コード）
class SearchService
  def search(query)
    # 検索DBが重くなると...
    results = SlowSearchDB.query(query)  # タイムアウト30秒
    # → このリクエストを処理するスレッドが30秒間ブロック
    # → スレッドプールが枯渇
    # → 注文処理のリクエストも捌けなくなる
    # → サイト全体が停止
  end
end

# マイクロサービスでの障害分離
# 検索サービスが落ちても...
class OrdersController < ApplicationController
  def create
    # サーキットブレーカーが検索サービスの障害を検知
    # → 注文処理は独立して継続
    order = OrderService.create(params)
    render json: order, status: :created
  end
end

# ECS サービス定義 — 機能ごとに独立したスケール設定
# 検索サービス: セールで検索が集中するのでスケールアウト
search-service:
  desired_count: 20
  cpu: 1024
  memory: 2048
 
# 注文サービス: 通常のスケール
order-service:
  desired_count: 5
  cpu: 512
  memory: 1024
 
# ユーザーサービス: 軽量
user-service:
  desired_count: 3
  cpu: 256
  memory: 512

# 悪い例: 責任が混在したサービス
class ProductAndOrderAndUserService
  def create_order(user_id, product_id, quantity)
    user = fetch_user(user_id)           # ユーザーの責任
    product = fetch_product(product_id)  # 商品の責任
    order = create_order_record(...)     # 注文の責任
    send_email(user, order)              # 通知の責任
  end
end
 
# 良い例: 責任が明確
class OrderService
  def create_order(user_id, product_id, quantity)
    # 注文の作成だけに集中
    # ユーザー情報はUser Serviceから取得（API経由）
    # 商品情報はProduct Serviceから取得（API経由）
    # 通知はNotification Serviceに委譲（イベント経由）
    order = Order.create!(...)
    publish_event('order_created', order)
    order
  end
end

# 悪い例: 密結合した設定
# order-service は product-service の内部実装に依存
order_service:
  environment:
    PRODUCT_DB_HOST: product-postgres
    PRODUCT_DB_PORT: 5432
    PRODUCT_TABLE_NAME: products_v2
 
# 良い例: インターフェースのみに依存
order_service:
  environment:
    PRODUCT_SERVICE_URL: http://product-service
    PRODUCT_SERVICE_VERSION: v1

# 絶対にやってはいけないこと
module OrderService
  class Order < ApplicationRecord
    # OrderServiceのコードがProductServiceのDBに直接アクセス
    def product
      ProductServiceDatabase::Product.find(product_id)
    end
  end
end
 
# 正しい方法: APIを通じてアクセス
module OrderService
  class Order < ApplicationRecord
    def product
      ProductServiceClient.find(product_id)
    end
  end
end

# app/services/product_service_client.rb
class ProductServiceClient
  def self.find(product_id)
    response = HTTP.timeout(2).get("#{BASE_URL}/products/#{product_id}")
    JSON.parse(response.body)
  rescue HTTP::TimeoutError, HTTP::ConnectionError => e
    # サービスが落ちていても graceful degradation
    Rails.logger.error("ProductService unavailable: #{e.message}")
    { id: product_id, name: '商品情報取得中', price: 0 }  # フォールバック
  end
end