はじめに
Javaアプリケーション開発において、適切な例外処理は信頼性の高いシステムを構築する上で極めて重要です。例外処理を適切に実装することで、予期せぬエラーに対して堅牢に対応し、システムの安定性を確保することができます。
本記事では、Java開発における例外処理の基礎から実践的な実装例まで、7つの重要なトピックに分けて詳しく解説します。現場でよく遭遇する状況に対する具体的な対処法や、Spring Frameworkを使用した実装例なども含め、実践的な知識を提供します。
この記事を読むことで、以下のような知識とスキルを習得できます。
本記事で学べること
- 例外処理の基本概念と適切な使い方
- 実務で使える例外処理のベストプラクティス
- Spring Frameworkにおける効果的な例外処理方法
- データベース操作、外部API連携、マルチスレッド環境での例外処理実装
それでは、各トピックについて詳しく見ていきましょう。
１．Java例外処理の基礎知識
1.1 例外処理が必要な理由と基本概念
プログラムの実行中には様々な予期せぬ状況が発生する可能性があります。ファイルが見つからない、ネットワーク接続が切れる、メモリが不足するなど、これらの異常系に適切に対応することは、堅牢なアプリケーション開発には不可欠です。
例外処理の重要性
● プログラムの異常終了を防ぐ
● エラー発生時の適切な処理を実現する
● デバッグ情報の取得と問題の追跡を容易にする
● ユーザーへの適切なフィードバックを提供する
Javaの例外階層構造
// Throwableクラスを頂点とする例外の階層構造
Throwable
├── Error // 深刻なエラー（通常回復不可能）
│ ├── OutOfMemoryError
│ └── StackOverflowError
└── Exception // プログラムで処理可能な例外
├── IOException // チェック例外の例
└── RuntimeException // 非チェック例外の例
├── NullPointerException
└── IllegalArgumentException
1.2 チェック例外とランタイム例外の違いと使い分け
チェック例外（検査例外）
● コンパイル時にチェックされる例外
● try-catchによる処理か、throwsによる宣言が必須
● 回復可能な例外を表現する際に使用
// チェック例外の例
public void readFile(String path) throws IOException {
// ファイル処理でIOExceptionが発生する可能性がある
BufferedReader reader = new BufferedReader(new FileReader(path));
// ...
}
ランタイム例外（非検査例外）
● コンパイル時のチェックが不要
● プログラムのバグを表現することが多い
● 通常、上位層でまとめて処理
// ランタイム例外の例
public void processData(String data) {
if (data == null) {
throw new IllegalArgumentException("データがnullです");
}
// 処理続行
}
使い分けの指針
| 例外の種類 | 使用すべき状況 | 例 |
|---|---|---|
| チェック例外 | 回復可能なエラー | ファイルアクセス、ネットワーク接続 |
| ランタイム例外 | プログラミングエラー | null参照、不正な引数 |
1.3 try-catch-finallyブロックの基本的な使い方
基本構文
try {
// 例外が発生する可能性のある処理
riskyOperation();
} catch (SpecificException e) {
// 特定の例外をキャッチして処理
handleSpecificException(e);
} catch (Exception e) {
// その他の例外をキャッチ
handleGenericException(e);
} finally {
// 必ず実行される処理
cleanup();
}
実践的な使用例
public class FileProcessor {
public String readFileContent(String filePath) {
BufferedReader reader = null;
StringBuilder content = new StringBuilder();
try {
// ファイルを開いて読み込み
reader = new BufferedReader(new FileReader(filePath));
String line;
while ((line = reader.readLine()) != null) {
content.append(line).append("\n");
}
return content.toString();
} catch (FileNotFoundException e) {
// ファイルが存在しない場合の処理
log.error("ファイルが見つかりません: " + filePath, e);
throw new BusinessException("指定されたファイルが存在しません", e);
} catch (IOException e) {
// その他のIO例外の処理
log.error("ファイル読み込み中にエラーが発生しました", e);
throw new BusinessException("ファイル処理中にエラーが発生しました", e);
} finally {
// リソースのクリーンアップ
if (reader != null) {
try {
reader.close();
} catch (IOException e) {
log.warn("ファイルのクローズに失敗しました", e);
}
}
}
}
}
try-catch-finallyブロックの注意点
- 具体的な例外から順にキャッチする
- finallyブロックは必ず実行される
- finallyブロック内でも例外処理を考慮する
- 例外を適切にログ出力する
このような基本的な例外処理の理解は、より高度な例外処理パターンを学ぶ基礎となります。
２．例外処理の実装パターン
2.1 try-with-resourcesを使用したリソース管理
Java 7で導入されたtry-with-resources構文は、AutoCloseableインターフェースを実装したリソースの自動クローズを実現します。これにより、リソースリークを防ぎ、コードの可読性も向上します。
基本的な使用方法
// 従来の方法
BufferedReader reader = null;
try {
reader = new BufferedReader(new FileReader("data.txt"));
// 処理
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e) {
// クローズ時の例外処理
}
}
}
// try-with-resourcesを使用した方法
try (BufferedReader reader = new BufferedReader(new FileReader("data.txt"))) {
// 処理
// closeは自動的に呼び出される
}
複数リソースの管理
public void processFiles(String inputPath, String outputPath) {
try (BufferedReader reader = new BufferedReader(new FileReader(inputPath));
BufferedWriter writer = new BufferedWriter(new FileWriter(outputPath))) {
String line;
while ((line = reader.readLine()) != null) {
writer.write(line);
writer.newLine();
}
} catch (IOException e) {
log.error("ファイル処理中にエラーが発生しました", e);
throw new BusinessException("ファイル処理に失敗しました", e);
}
}
2.2 マルチキャッチによる効率的な例外ハンドリング
Java 7以降では、複数の例外を1つのcatchブロックで処理できます。これにより、コードの重複を減らし、メンテナンス性を向上できます。
マルチキャッチの実装例
public void processData() {
try {
// データベース処理とファイル処理
saveToDatabase();
writeToFile();
} catch (SQLException | IOException e) {
// 複数の例外を同じように処理
log.error("データ処理中にエラーが発生しました", e);
throw new SystemException("システムエラーが発生しました", e);
} catch (Exception e) {
// その他の例外処理
log.error("予期せぬエラーが発生しました", e);
throw new UnexpectedSystemException("予期せぬエラーが発生しました", e);
}
}
2.3 カスタム例外クラスの設計と実装方法
ビジネスロジック特有の例外を表現するために、カスタム例外クラスを作成することは有効な手段です。
カスタム例外クラスの基本構造
public class BusinessException extends Exception {
private final String errorCode;
private final ErrorSeverity severity;
public BusinessException(String message, String errorCode, ErrorSeverity severity) {
super(message);
this.errorCode = errorCode;
this.severity = severity;
}
public BusinessException(String message, String errorCode, ErrorSeverity severity, Throwable cause) {
super(message, cause);
this.errorCode = errorCode;
this.severity = severity;
}
public String getErrorCode() {
return errorCode;
}
public ErrorSeverity getSeverity() {
return severity;
}
}
// 例外の重要度を表す列挙型
public enum ErrorSeverity {
INFO, WARNING, ERROR, CRITICAL
}
カスタム例外の使用例
public class UserService {
public void registerUser(UserDto userDto) {
try {
validateUser(userDto);
// ユーザー登録処理
} catch (ValidationException e) {
throw new BusinessException(
"ユーザー登録に失敗しました",
"ERR001",
ErrorSeverity.WARNING,
e
);
} catch (DatabaseException e) {
throw new BusinessException(
"システムエラーが発生しました",
"ERR002",
ErrorSeverity.CRITICAL,
e
);
}
}
private void validateUser(UserDto userDto) throws ValidationException {
if (userDto.getEmail() == null || !userDto.getEmail().contains("@")) {
throw new ValidationException("不正なメールアドレス形式です");
}
// その他のバリデーション
}
}
カスタム例外設計のベストプラクティス
1. 例外の階層構造を適切に設計する
// 基底となる例外クラス
public abstract class BaseException extends Exception {
// 共通の機能を実装
}
// 具体的な例外クラス
public class ValidationException extends BaseException {
// バリデーション特有の機能を追加
}
2. 意味のある情報を付加する
● エラーコード
● 重要度
● タイムスタンプ
● トランザクションID
3. ログ出力を考慮した設計
public class LoggableException extends Exception {
public String getLoggableMessage() {
return String.format("[%s] %s - %s",
getTimestamp(),
getErrorCode(),
getMessage());
}
}
これらのパターンを適切に組み合わせることで、保守性が高く、堅牢な例外処理を実現できます。
３．実務で役立つ例外処理のベストプラクティス
3.1 適切な粒度での例外キャッチ
例外処理の粒度は、アプリケーションの保守性と回復性に大きな影響を与えます。適切な粒度で例外をキャッチすることで、より細やかなエラーハンドリングが可能になります。
粒度別の例外処理パターン
public class OrderService {
// 不適切な例: 粒度が粗すぎる
public void processOrder_Bad(Order order) {
try {
// 全ての処理を1つのtryブロックで囲む
validateOrder(order);
calculateTotal(order);
checkInventory(order);
saveToDatabase(order);
sendConfirmationEmail(order);
} catch (Exception e) {
// 全ての例外を同じように処理
log.error("注文処理でエラーが発生しました", e);
throw new OrderProcessingException("注文処理に失敗しました", e);
}
}
// 適切な例: 処理段階ごとの例外ハンドリング
public void processOrder_Good(Order order) {
try {
validateOrder(order);
} catch (ValidationException e) {
log.warn("注文データが不正です", e);
throw new InvalidOrderException("注文内容を確認してください", e);
}
try {
calculateTotal(order);
checkInventory(order);
} catch (InventoryException e) {
log.error("在庫チェックに失敗しました", e);
throw new OrderProcessingException("商品の在庫が不足しています", e);
} catch (CalculationException e) {
log.error("金額計算に失敗しました", e);
throw new OrderProcessingException("注文金額の計算に失敗しました", e);
}
try {
saveToDatabase(order);
} catch (DatabaseException e) {
log.error("データベース保存に失敗しました", e);
throw new SystemException("システムエラーが発生しました", e);
}
try {
sendConfirmationEmail(order);
} catch (EmailException e) {
// メール送信失敗は処理続行可能
log.warn("確認メールの送信に失敗しました", e);
}
}
}
3.2 意味のある例外メッセージの作成方法
例外メッセージは、問題の診断と解決に重要な役割を果たします。以下のポイントを考慮して、意味のある例外メッセージを作成しましょう。
効果的な例外メッセージの要素
1. エラーの発生場所
2. エラーの原因
3. 期待される状態と実際の状態
4. 可能な解決策
public class ValidationUtil {
public static void validateAge(int age) {
// 不適切な例
if (age < 0) {
throw new IllegalArgumentException("Invalid age");
}
// 適切な例
if (age < 0) {
throw new IllegalArgumentException(
String.format("年齢は0以上の値である必要があります。指定された値: %d", age)
);
}
}
public static void validateEmail(String email) {
if (email == null || !email.matches("^[A-Za-z0-9+_.-]+@(.+)$")) {
throw new ValidationException(
String.format("不正なメールアドレス形式です。[%s] " +
"正しいメールアドレス形式（例：example@domain.com）で入力してください。",
email)
);
}
}
}
3.3 例外のラップと再スロー戦略
下位レイヤーの例外を上位レイヤーに伝播させる際は、適切なラップと再スローを行うことで、より意味のある例外情報を提供できます。
例外ラップの実装例
public class UserRepository {
public User findById(Long userId) {
try {
return jdbcTemplate.queryForObject(
"SELECT * FROM users WHERE id = ?",
new Object[]{userId},
userRowMapper
);
} catch (DataAccessException e) {
// 技術的な例外をビジネス例外に変換
throw new UserNotFoundException(
String.format("ID: %dのユーザーが見つかりません", userId),
e
);
} catch (SQLException e) {
// SQLExceptionをシステム例外にラップ
throw new SystemException(
"データベースアクセス中にエラーが発生しました",
"DB_ERROR",
e
);
}
}
}
効果的な例外チェーンの作成
public class OrderManager {
public void processOrder(OrderRequest request) {
try {
// 注文処理
Order order = createOrder(request);
validateOrder(order);
saveOrder(order);
} catch (ValidationException e) {
// バリデーション例外は変換せずに再スロー
throw e;
} catch (DatabaseException e) {
// データベース例外をビジネス例外に変換
throw new OrderProcessingException(
"注文の保存に失敗しました",
"ORD001",
ErrorSeverity.ERROR,
e
);
} catch (Exception e) {
// 予期せぬ例外をシステム例外にラップ
throw new UnexpectedSystemException(
"注文処理中に予期せぬエラーが発生しました",
"SYS001",
e
);
}
}
}
例外ラップのベストプラクティス
- 原因となった例外を必ず含める（cause）
- スタックトレースを保持する
- 意味のある追加情報を付加する
- 適切な例外階層を維持する
これらのベストプラクティスを実践することで、より保守性の高い、デバッグしやすい例外処理を実現できます。
４．アプリケーション設計における例外処理
4.1 レイヤー別の例外ハンドリング戦略
マルチレイヤーアーキテクチャにおいて、各レイヤーでの適切な例外処理戦略は、アプリケーションの保守性と拡張性を高めます。
レイヤー別の例外処理方針
// Presentationレイヤー（Controller）
@RestController
public class UserController {
@PostMapping("/users")
public ResponseEntity<UserResponse> createUser(@RequestBody UserRequest request) {
try {
UserResponse response = userService.createUser(request);
return ResponseEntity.ok(response);
} catch (ValidationException e) {
// バリデーションエラーは400エラーとして返却
return ResponseEntity.badRequest()
.body(new ErrorResponse(e.getMessage()));
} catch (BusinessException e) {
// ビジネスロジックエラーは409エラーとして返却
return ResponseEntity.status(HttpStatus.CONFLICT)
.body(new ErrorResponse(e.getMessage()));
}
}
}
// Businessレイヤー（Service）
@Service
public class UserService {
public UserResponse createUser(UserRequest request) {
try {
validateUserRequest(request);
User user = userRepository.save(convertToEntity(request));
return convertToResponse(user);
} catch (DataAccessException e) {
// インフラストラクチャの例外をビジネス例外に変換
throw new BusinessException("ユーザー作成に失敗しました", e);
}
}
}
// Infrastructureレイヤー（Repository）
@Repository
public class UserRepository {
public User save(User user) {
try {
return entityManager.persist(user);
} catch (PersistenceException e) {
// 永続化層の例外をRepository層の例外に変換
throw new DataAccessException("データベース保存に失敗しました", e);
}
}
}
4.2 ログ出力を考慮した例外設計
効果的なログ出力は、問題の早期発見と解決に不可欠です。例外処理とログ出力を統合的に設計することで、運用性を向上させることができます。
ログレベルの使い分け
public class OrderService {
private static final Logger log = LoggerFactory.getLogger(OrderService.class);
public Order processOrder(OrderRequest request) {
// DEBUGレベル：詳細な処理の開始・終了
log.debug("注文処理開始: {}", request.getOrderId());
try {
validateOrder(request);
// INFOレベル：重要な業務イベント
log.info("注文バリデーション成功: {}", request.getOrderId());
Order order = createOrder(request);
// INFOレベル：処理の成功
log.info("注文作成成功: {}", order.getId());
return order;
} catch (ValidationException e) {
// WARNレベル：想定内のエラー
log.warn("注文バリデーションエラー: {} - {}",
request.getOrderId(), e.getMessage());
throw e;
} catch (Exception e) {
// ERRORレベル：想定外のエラー
log.error("注文処理中に予期せぬエラーが発生: {} - {}",
request.getOrderId(), e.getMessage(), e);
throw new SystemException("システムエラーが発生しました", e);
}
}
}
構造化ログ出力の実装
public class LoggingAspect {
private static final Logger log = LoggerFactory.getLogger(LoggingAspect.class);
@Around("execution(* com.example.service.*.*(..))")
public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable {
// メソッド実行前のログ
LogContext context = new LogContext()
.setMethod(joinPoint.getSignature().getName())
.setArgs(joinPoint.getArgs())
.setStartTime(System.currentTimeMillis());
try {
Object result = joinPoint.proceed();
// 正常終了時のログ
context.setEndTime(System.currentTimeMillis())
.setStatus("SUCCESS");
log.info("{}", context);
return result;
} catch (Exception e) {
// 異常終了時のログ
context.setEndTime(System.currentTimeMillis())
.setStatus("ERROR")
.setException(e);
log.error("{}", context);
throw e;
}
}
}
4.3 テスト容易性を高める例外処理の実装
例外処理のテストは、アプリケーションの品質を保証する重要な要素です。テスタビリティを考慮した例外処理の実装を心がけましょう。
テスト容易な例外処理の実装例
public class UserService {
private final UserRepository userRepository;
private final ValidationService validationService;
// コンストラクタインジェクションでテスト容易性を確保
public UserService(UserRepository userRepository,
ValidationService validationService) {
this.userRepository = userRepository;
this.validationService = validationService;
}
public User createUser(UserRequest request) {
// バリデーションを分離してテスト可能に
ValidationResult result = validationService.validate(request);
if (!result.isValid()) {
throw new ValidationException(result.getErrors());
}
try {
return userRepository.save(convertToEntity(request));
} catch (DataAccessException e) {
throw new BusinessException("ユーザー作成に失敗しました", e);
}
}
}
// テストコード
@Test
public void createUser_ValidationError_ThrowsException() {
// モックの準備
UserRepository mockRepo = mock(UserRepository.class);
ValidationService mockValidation = mock(ValidationService.class);
UserService service = new UserService(mockRepo, mockValidation);
// テストデータ
UserRequest request = new UserRequest("test@example.com");
ValidationResult invalidResult = new ValidationResult(false,
Arrays.asList("Invalid email"));
// モックの振る舞いを設定
when(mockValidation.validate(request)).thenReturn(invalidResult);
// 例外発生の検証
assertThrows(ValidationException.class,
() -> service.createUser(request));
}
これらの設計パターンを適切に組み合わせることで、保守性が高く、テストしやすい例外処理を実現できます。
５．よくある実装ミスと改善方法
5.1 空のcatchブロックが引き起こす問題
空のcatchブロックは、エラーを隠蔽し、問題の追跡を困難にする最も一般的な実装ミスの1つです。
問題のある実装例
// 悪い例：空のcatchブロック
public void processFile(String path) {
try {
Files.delete(Paths.get(path));
} catch (IOException e) {
// 何もしない - 危険な実装
}
}
// 改善例1：最低限のログ出力
public void processFile(String path) {
try {
Files.delete(Paths.get(path));
} catch (IOException e) {
log.error("ファイル削除に失敗しました: " + path, e);
throw new SystemException("ファイル操作に失敗しました", e);
}
}
// 改善例2：代替処理の実装
public void processFile(String path) {
try {
Files.delete(Paths.get(path));
} catch (IOException e) {
log.warn("通常の削除に失敗しました。強制削除を試みます: " + path, e);
try {
File file = new File(path);
if (!file.delete()) {
log.error("強制削除も失敗しました: " + path);
throw new SystemException("ファイル削除に失敗しました", e);
}
} catch (SecurityException se) {
throw new SystemException("ファイル削除の権限がありません", se);
}
}
}
5.2 例外を無視することの危険性
例外を無視することは、重大な問題を見落とす原因となり、システムの信頼性を損なう可能性があります。
危険な例外無視のパターン
// 危険な実装：例外を握りつぶす
public class ConnectionManager {
private static Connection connection;
// 問題のある実装
public static void closeQuietly() {
try {
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
// 危険：接続が正しく閉じられない可能性を無視
}
}
// 改善された実装
public static void close() throws SQLException {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
log.error("データベース接続のクローズに失敗しました", e);
throw e; // 上位層に問題を通知
} finally {
connection = null; // リソースの解放を確実に
}
}
}
}
5.3 過剰な例外キャッチを避ける方法
必要以上に広範囲な例外をキャッチすることは、エラーの適切な処理を妨げる可能性があります。
適切な例外キャッチの例
// 不適切な実装：過剰な例外キャッチ
public class UserService {
public void registerUser(UserDto dto) {
try {
// 様々な処理
validateUser(dto);
saveUser(dto);
sendWelcomeEmail(dto);
} catch (Exception e) { // 全ての例外を同じように処理
log.error("ユーザー登録エラー", e);
throw new SystemException("システムエラーが発生しました");
}
}
// 改善された実装：適切な粒度での例外処理
public void registerUser(UserDto dto) {
// バリデーション
try {
validateUser(dto);
} catch (ValidationException e) {
log.warn("ユーザー情報が不正です", e);
throw new InvalidUserDataException("入力内容を確認してください", e);
}
// データベース保存
try {
saveUser(dto);
} catch (DataAccessException e) {
log.error("ユーザーの保存に失敗しました", e);
throw new SystemException("データベースエラーが発生しました", e);
}
// メール送信（非クリティカルな処理）
try {
sendWelcomeEmail(dto);
} catch (EmailException e) {
// メール送信失敗はユーザー登録処理を中断しない
log.warn("ウェルカムメールの送信に失敗しました", e);
}
}
}
例外処理改善のチェックリスト
1. 例外ハンドリングの基本原則
● 空のcatchブロックを作らない
● 適切なログ出力を行う
● 例外を適切な粒度でキャッチする
● 例外を意図的に無視する場合はコメントで理由を明記する
2. コードレビューでのチェックポイント
● 例外がログに適切に記録されているか
● スタックトレースが保持されているか
● 例外の変換が適切に行われているか
● リソースが確実に解放されているか
3. 改善のための具体的なアクション
● 空のcatchブロックの撲滅
● 適切なログレベルの使用
● 例外処理の責任範囲の明確化
● テスト可能な例外処理の実装
これらの問題を認識し、適切に対処することで、より堅牢なアプリケーションを実現できます。
６．Spring Frameworkにおける例外処理
6.1 @ExceptionHandlerの効果的な使い方
Spring MVCでは、@ExceptionHandlerアノテーションを使用して、コントローラーレベルやグローバルレベルで例外処理を一元化できます。
コントローラーレベルの例外ハンドリング
@RestController
@RequestMapping("/api/users")
public class UserController {
// 個別のコントローラー内での例外ハンドリング
@ExceptionHandler(UserNotFoundException.class)
@ResponseStatus(HttpStatus.NOT_FOUND)
public ErrorResponse handleUserNotFound(UserNotFoundException ex) {
return new ErrorResponse(
"USER_NOT_FOUND",
ex.getMessage(),
HttpStatus.NOT_FOUND.value()
);
}
@ExceptionHandler(ValidationException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
public ErrorResponse handleValidation(ValidationException ex) {
return new ErrorResponse(
"VALIDATION_ERROR",
ex.getMessage(),
HttpStatus.BAD_REQUEST.value()
);
}
@GetMapping("/{id}")
public UserResponse getUser(@PathVariable Long id) {
return userService.findById(id)
.orElseThrow(() -> new UserNotFoundException(
String.format("ユーザーID %d が見つかりません", id)
));
}
}
6.2 ResponseEntityを使用したエラーレスポンスの設計
APIのエラーレスポンスは、クライアントが適切に処理できるよう、一貫性のある形式で設計する必要があります。
エラーレスポンスの標準化
// エラーレスポンスのDTO
@Getter
@AllArgsConstructor
public class ErrorResponse {
private final String code;
private final String message;
private final int status;
private final LocalDateTime timestamp;
private final List<String> details;
// ファクトリーメソッド
public static ErrorResponse of(String code, String message,
HttpStatus status, List<String> details) {
return new ErrorResponse(
code,
message,
status.value(),
LocalDateTime.now(),
details
);
}
}
// バリデーションエラーの詳細情報
@Getter
@AllArgsConstructor
public class ValidationErrorDetail {
private final String field;
private final Object rejectedValue;
private final String message;
}
// ResponseEntityを使用したレスポンス生成
@ExceptionHandler(MethodArgumentNotValidException.class)
public ResponseEntity<ErrorResponse> handleValidationErrors(
MethodArgumentNotValidException ex) {
List<String> details = ex.getBindingResult()
.getFieldErrors()
.stream()
.map(error -> String.format(
"フィールド '%s' の値 '%s' が不正です: %s",
error.getField(),
error.getRejectedValue(),
error.getDefaultMessage()
))
.collect(Collectors.toList());
ErrorResponse error = ErrorResponse.of(
"VALIDATION_ERROR",
"入力値が不正です",
HttpStatus.BAD_REQUEST,
details
);
return ResponseEntity
.status(HttpStatus.BAD_REQUEST)
.body(error);
}
6.3 グローバル例外ハンドラーの実装方法
@ControllerAdviceを使用することで、アプリケーション全体で一貫した例外処理を実現できます。
グローバル例外ハンドラーの実装
@ControllerAdvice
public class GlobalExceptionHandler extends ResponseEntityExceptionHandler {
private static final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
// ビジネス例外のハンドリング
@ExceptionHandler(BusinessException.class)
public ResponseEntity<ErrorResponse> handleBusinessException(
BusinessException ex, WebRequest request) {
log.warn("ビジネスロジックエラーが発生しました", ex);
ErrorResponse error = ErrorResponse.of(
ex.getErrorCode(),
ex.getMessage(),
HttpStatus.CONFLICT,
Collections.singletonList(ex.getDetail())
);
return ResponseEntity
.status(HttpStatus.CONFLICT)
.body(error);
}
// システム例外のハンドリング
@ExceptionHandler(SystemException.class)
public ResponseEntity<ErrorResponse> handleSystemException(
SystemException ex, WebRequest request) {
log.error("システムエラーが発生しました", ex);
ErrorResponse error = ErrorResponse.of(
"SYSTEM_ERROR",
"システムエラーが発生しました",
HttpStatus.INTERNAL_SERVER_ERROR,
Collections.emptyList() // システムエラーの詳細は外部に公開しない
);
return ResponseEntity
.status(HttpStatus.INTERNAL_SERVER_ERROR)
.body(error);
}
// バリデーション例外のハンドリング
@Override
protected ResponseEntity<Object> handleMethodArgumentNotValid(
MethodArgumentNotValidException ex,
HttpHeaders headers,
HttpStatusCode status,
WebRequest request) {
List<ValidationErrorDetail> validationErrors = ex.getBindingResult()
.getFieldErrors()
.stream()
.map(error -> new ValidationErrorDetail(
error.getField(),
error.getRejectedValue(),
error.getDefaultMessage()
))
.collect(Collectors.toList());
ErrorResponse error = ErrorResponse.of(
"VALIDATION_ERROR",
"入力値が不正です",
HttpStatus.BAD_REQUEST,
validationErrors.stream()
.map(Object::toString)
.collect(Collectors.toList())
);
return ResponseEntity
.status(HttpStatus.BAD_REQUEST)
.body(error);
}
// 予期せぬ例外のハンドリング
@ExceptionHandler(Exception.class)
public ResponseEntity<ErrorResponse> handleAllUncaughtException(
Exception ex, WebRequest request) {
log.error("予期せぬエラーが発生しました", ex);
ErrorResponse error = ErrorResponse.of(
"UNEXPECTED_ERROR",
"予期せぬエラーが発生しました",
HttpStatus.INTERNAL_SERVER_ERROR,
Collections.emptyList()
);
return ResponseEntity
.status(HttpStatus.INTERNAL_SERVER_ERROR)
.body(error);
}
}
このように、Spring Frameworkを使用することで、体系的で一貫性のある例外処理を実現できます。
７．実践的な例外処理の実装例
7.1 データベース操作時の例外ハンドリング
データベース操作では、様々な例外が発生する可能性があります。トランザクション管理と組み合わせた適切な例外処理が重要です。
JDBCを使用したデータベース操作の例外処理
@Service
@Transactional
public class OrderService {
private final DataSource dataSource;
private static final Logger log = LoggerFactory.getLogger(OrderService.class);
public OrderService(DataSource dataSource) {
this.dataSource = dataSource;
}
public void createOrder(Order order) {
Connection conn = null;
PreparedStatement stmt = null;
try {
conn = dataSource.getConnection();
conn.setAutoCommit(false); // トランザクション開始
// 注文データの保存
stmt = conn.prepareStatement(
"INSERT INTO orders (customer_id, total_amount, status) VALUES (?, ?, ?)",
Statement.RETURN_GENERATED_KEYS
);
stmt.setLong(1, order.getCustomerId());
stmt.setBigDecimal(2, order.getTotalAmount());
stmt.setString(3, OrderStatus.CREATED.name());
stmt.executeUpdate();
// 生成されたIDの取得
try (ResultSet rs = stmt.getGeneratedKeys()) {
if (rs.next()) {
order.setId(rs.getLong(1));
} else {
throw new DatabaseException("注文IDの取得に失敗しました");
}
}
// 注文詳細の保存
saveOrderDetails(conn, order);
conn.commit(); // トランザクションのコミット
} catch (SQLException e) {
try {
if (conn != null) {
conn.rollback(); // エラー時はロールバック
}
} catch (SQLException rollbackEx) {
log.error("トランザクションのロールバックに失敗しました", rollbackEx);
}
throw new DatabaseException("注文の保存に失敗しました", e);
} finally {
// リソースの解放
try {
if (stmt != null) stmt.close();
if (conn != null) conn.close();
} catch (SQLException e) {
log.warn("リソースの解放に失敗しました", e);
}
}
}
}
7.2 外部APIとの連携における例外処理
外部APIとの連携では、ネットワークの問題や応答タイムアウトなど、様々な例外が発生する可能性があります。
RestTemplateを使用したAPI連携の例外処理
@Service
public class PaymentService {
private final RestTemplate restTemplate;
private final ObjectMapper objectMapper;
private static final Logger log = LoggerFactory.getLogger(PaymentService.class);
// リトライ設定
private final RetryTemplate retryTemplate = RetryTemplate.builder()
.maxAttempts(3)
.exponentialBackoff(100, 2, 1000)
.build();
public PaymentResult processPayment(PaymentRequest request) {
try {
return retryTemplate.execute(context -> {
try {
ResponseEntity<PaymentResult> response = restTemplate.postForEntity(
"https://api.payment.example.com/v1/payments",
request,
PaymentResult.class
);
return response.getBody();
} catch (HttpClientErrorException e) {
// クライアントエラー（400系）の処理
PaymentError error = parseError(e.getResponseBodyAsString());
throw new PaymentValidationException(
"支払い処理が拒否されました: " + error.getMessage(),
error.getCode()
);
} catch (HttpServerErrorException e) {
// サーバーエラー（500系）の処理
log.error("支払いサーバーでエラーが発生しました: {}",
e.getResponseBodyAsString());
throw new RetryableException("サーバーエラーが発生しました", e);
} catch (ResourceAccessException e) {
// ネットワークエラーの処理
log.error("支払いサーバーへの接続に失敗しました", e);
throw new RetryableException("ネットワークエラーが発生しました", e);
}
});
} catch (RetryableException e) {
// リトライ失敗時の処理
throw new PaymentProcessingException(
"支払い処理に失敗しました。しばらく経ってから再度お試しください。",
e
);
}
}
private PaymentError parseError(String errorResponse) {
try {
return objectMapper.readValue(errorResponse, PaymentError.class);
} catch (JsonProcessingException e) {
log.warn("エラーレスポンスのパースに失敗しました", e);
throw new PaymentProcessingException("不明なエラーが発生しました", e);
}
}
}
7.3 マルチスレッド環境での例外処理
マルチスレッド環境では、各スレッドで発生した例外を適切に処理し、必要に応じてメインスレッドに通知する必要があります。
ExecutorServiceを使用した並列処理の例外処理
@Service
public class BatchProcessingService {
private final ExecutorService executorService;
private static final Logger log = LoggerFactory.getLogger(BatchProcessingService.class);
public BatchProcessingService() {
this.executorService = Executors.newFixedThreadPool(
Runtime.getRuntime().availableProcessors()
);
}
public List<ProcessResult> processBatch(List<BatchItem> items) {
try {
// 各アイテムの処理をSubmit
List<Future<ProcessResult>> futures = items.stream()
.map(item -> executorService.submit(() -> processItem(item)))
.collect(Collectors.toList());
// 結果の収集
List<ProcessResult> results = new ArrayList<>();
for (Future<ProcessResult> future : futures) {
try {
results.add(future.get(30, TimeUnit.SECONDS));
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new BatchProcessingException(
"処理が中断されました", e);
} catch (ExecutionException e) {
// スレッド内で発生した例外の処理
log.error("アイテム処理中にエラーが発生しました", e.getCause());
results.add(ProcessResult.error(
"処理に失敗しました: " + e.getCause().getMessage()));
} catch (TimeoutException e) {
log.warn("処理がタイムアウトしました", e);
results.add(ProcessResult.error("処理がタイムアウトしました"));
}
}
return results;
} finally {
// ExecutorServiceのシャットダウン
executorService.shutdown();
try {
if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
executorService.shutdownNow();
}
} catch (InterruptedException e) {
executorService.shutdownNow();
Thread.currentThread().interrupt();
}
}
}
private ProcessResult processItem(BatchItem item) {
try {
// アイテムの処理ロジック
validateItem(item);
Result result = performProcessing(item);
return ProcessResult.success(result);
} catch (ValidationException e) {
log.warn("バリデーションエラー: {}", e.getMessage());
return ProcessResult.error("バリデーションエラー: " + e.getMessage());
} catch (ProcessingException e) {
log.error("処理エラー: {}", e.getMessage());
return ProcessResult.error("処理エラー: " + e.getMessage());
} catch (Exception e) {
log.error("予期せぬエラーが発生しました", e);
return ProcessResult.error("予期せぬエラーが発生しました");
}
}
}
@Getter
@AllArgsConstructor
public class ProcessResult {
private final boolean success;
private final String message;
private final Result result;
public static ProcessResult success(Result result) {
return new ProcessResult(true, "処理が成功しました", result);
}
public static ProcessResult error(String message) {
return new ProcessResult(false, message, null);
}
}
これらの実装例は、実際のプロジェクトでよく遭遇する状況に対する具体的な例外処理の方法を示しています。それぞれの状況に応じて、適切な例外処理戦略を選択し、実装することが重要です。
まとめ：効果的な例外処理の実現に向けて
本記事では、Javaにおける例外処理について、基礎から実践的な実装例まで幅広く解説してきました。ここで学んだ主要なポイントを振り返ってみましょう。
重要なポイントの整理
1. 例外処理の基本原則
● 適切な例外の種類選択（チェック例外 vs ランタイム例外）
● try-with-resourcesによる確実なリソース管理
● 意味のある例外メッセージの作成
2. 実装における注意点
● 空のcatchブロックを避ける
● 適切な粒度での例外キャッチ
● 例外のラップと再スロー戦略の活用
3. アプリケーション設計のベストプラクティス
● レイヤー別の適切な例外ハンドリング
● 構造化されたログ出力の実装
● テスト容易性を考慮した設計
4. フレームワークとの統合
● Spring Frameworkにおける効果的な例外処理
● @ExceptionHandlerの適切な使用
● グローバル例外ハンドラーの実装
実装時のチェックリスト
効果的な例外処理を実現するため、以下のチェックリストを活用してください。
✅ 例外処理の基本
● 適切な例外クラスの選択
● 明確な例外メッセージの設定
● リソースの確実な解放
✅ コード品質
● 空のcatchブロックの排除
● 適切なログ出力の実装
● 例外チェーンの保持
✅ アプリケーション設計
● レイヤー別の例外戦略の定義
● エラーハンドリングの一貫性確保
● テスト容易性の確保
今後の学習に向けて
例外処理の実装スキルを更に向上させるために、以下のような取り組みをお勧めします。
1. 実践的な経験を積む
● 実際のプロジェクトでの実装
● さまざまなユースケースへの対応
● コードレビューを通じた改善
2. 最新動向のキャッチアップ
● Java言語の新機能確認
● フレームワークのアップデート把握
● コミュニティでの議論参加
3. テスト駆動開発の実践
● 例外ケースのテスト作成
● エッジケースの考慮
● テスト容易性の向上
おわりに
適切な例外処理は、堅牢なJavaアプリケーションを開発する上で不可欠な要素です。本記事で解説した内容を基に、プロジェクトの特性や要件に応じて、最適な例外処理を実装していってください。
エラー処理は往々にして後回しにされがちですが、プロジェクトの初期段階から適切な例外処理戦略を策定し、実装することで、長期的なメンテナンス性と信頼性の向上につながります。
本記事が、皆様の実務における例外処理の改善に役立つことを願っています。