カテゴリー: Java

投稿日:

【Java】PDFからJPG変換

PDFファイルに利用されている画像をJPG変換します。
以下のライブラリが必要です。
pdfbox-2.0.7.jar
commons-logging-1.2.jar

ソースを表示
印刷SyntaxHighlighterについて
1import java.io.File;
2import java.io.FileOutputStream;
3import java.io.IOException;
4import java.util.Iterator;
5 
6import javax.imageio.ImageIO;
7 
8import org.apache.pdfbox.cos.COSName;
9import org.apache.pdfbox.pdmodel.PDDocument;
10import org.apache.pdfbox.pdmodel.PDPage;
11import org.apache.pdfbox.pdmodel.PDPageTree;
12import org.apache.pdfbox.pdmodel.PDResources;
13import org.apache.pdfbox.pdmodel.graphics.PDXObject;
14import org.apache.pdfbox.pdmodel.graphics.image.PDImageXObject;
15 
16public class TestPDFBoxPdfToJpg {
17 
18    public static void main(String[] args) {
19        //PDFドキュメントをロード
20        try (PDDocument document = PDDocument.load(new File("D:\\test\\pdf\\e-ticket.pdf"));) {
21 
22            //ページのリストから最初の1ページを取得する
23            PDPageTree pageTree = document.getDocumentCatalog().getPages();
24            PDPage page = pageTree.get(0);
25 
26            //ページからリソースを取得し、最初のイメージを取得する。
27            PDResources resources = page.getResources();
28            Iterator<COSName> ite = resources.getXObjectNames().iterator();
29 
30            int i = 0;
31 
32            while (ite.hasNext()) {
33 
34                COSName name = ite.next();
35 
36                //取得したイメージをファイルに出力
37                PDXObject xobject = resources.getXObject(name);
38 
39                if (xobject instanceof PDImageXObject) {
40                    PDImageXObject image2 = (PDImageXObject) resources.getXObject(name);
41                    ImageIO.write(image2.getImage(), "jpg", new FileOutputStream("D:\\test\\pdf\\e-ticket" + i + ".jpg"));
42                }
43 
44                i++;
45            }
46 
47        } catch (IOException e) {
48            e.printStackTrace();
49        }
50    }
51}
投稿日:

【Java】例外内容を文字列で取得する

例外内容を文字列で取得します。
例外内容をメール本文等に出力する際に利用します。

ソースを表示
印刷SyntaxHighlighterについて
1/**
2 * 例外内容取得処理
3 * @param 例外オブジェクト
4 * @return 例外内容文字列
5 */
6public static String getTrace(Throwable th) {
7 
8    StringBuilder sb = new StringBuilder();
9    String lineSeparator = System.getProperty("line.separator");
10 
11    if (th != null) {
12        sb.append(th.getClass().getName() + ":" + th.getMessage());
13        StackTraceElement[] stack = th.getStackTrace();
14        if (stack != null) {
15            for (int i = 0; i < stack.length; i++) {
16                sb.append(lineSeparator);
17                sb.append("\tat " + stack[i].toString());
18            }
19        }
20        sb.append(lineSeparator);
21 
22        Throwable causeTh = th.getCause();
23        String caused = getCaused(causeTh);
24        sb.append(caused);
25    }
26 
27    return sb.toString();
28}
29 
30/**
31 * 例外内容取得処理(原因)
32 * @param 例外オブジェクト
33 * @return 例外内容文字列
34 */
35public static String getCaused(Throwable th) {
36 
37    StringBuilder sb = new StringBuilder();
38    String lineSeparator = System.getProperty("line.separator");
39    Throwable chainTh = null;
40 
41    if (th != null) {
42        sb.append("Caused by: " + th.getClass().getName() + ":" + th.getMessage());
43        StackTraceElement[] stack = th.getStackTrace();
44        if (stack != null) {
45            for (int i = 0; i < stack.length; i++) {
46                sb.append(lineSeparator);
47                sb.append("\tat " + stack[i].toString());
48            }
49        }
50        sb.append(lineSeparator);
51 
52        chainTh = th.getCause();
53 
54    } else {
55        return sb.toString();
56    }
57 
58    return sb.append(getCaused(chainTh)).toString();
59}
60 
61/**
62 * テストドライバ
63 * @param args
64 */
65public static void main(String[] args) {
66 
67    try {
68        test();
69    } catch (Throwable th) {
70        System.out.println("JavaAPIで例外出力");
71        th.printStackTrace();
72 
73        System.out.println();
74        System.out.println("独自APIで例外出力");
75        System.out.println(getTrace(th));
76    }
77}
78public static void test() throws Exception {
79    try {
80        try {
81            int i = 0;
82            int j = 100;
83            int k = j/i; // ここでエラー発生
84        } catch (Exception e) {
85            throw new Exception("エラー", e);
86        }
87    } catch (Exception e) {
88        //throw e;
89        throw new Exception("エラー２", e);
90    }
91}
投稿日:

【Java】BATからJava呼び出し

BATファイルからJava処理を呼び出します。

ソースを表示
印刷SyntaxHighlighterについて
1@echo off
2REM 空欄を指定した場合、後続処理でバッチ実行ディレクトリになる
3set USR_EXEDIR=C:\work\bin
4 
5echo START Java呼び出し
6 
7if "%USR_EXEDIR%" EQU "" (set USR_EXEDIR=%~dp0)
8cd /d %USR_EXEDIR%
9if %errorlevel% == 1 goto label_cderror
10 
11set LIB_DIR=C:\work\lib
12set EXE_PATH=.\sub.jar;..\db\ojdbc7.jar;%LIB_DIR%test.jar
13set CONF_DIR=..\conf
14set CLASS_PATH=.
15 
16set JAVA_OPTION=-Xms128M -Xmx128M -XX:MetaspaceSize=64M -XX:MaxMetaspaceSize=64M
17java %JAVA_OPTION% -classpath %EXE_PATH%;%CONF_DIR%;%CLASS_PATH%;jp.co.test.TestMain > nul
18 
19echo END Java呼び出し(0)
20exit %errorlevel%
21 
22:label_cderror
23echo END Java呼び出し(9)
24exit(9)
投稿日:

【Java】フォルダ解凍処理

フォルダ内のファイルを解凍します。

ソースを表示
印刷SyntaxHighlighterについて
1/**
2 * ファイル解凍処理
3 */
4private void deCompressFile() throws Exception {
5 
6  // 圧縮ストリームを宣言する。
7  ZipInputStream zis = null;
8 
9  try {
10    // 作業フォルダのファイルを解凍する。
11    zis = ZipInputStream(
12      new BufferedInputStream(
13        new FileInputStream(this.currentZipFileName)));
14 
15    // ファイルのエントリを宣言する。
16    ZipEntry entry;
17    // ファイルに含まれるエントリ分繰り返す。
18    while ((entry = zis.getNextEntry()) != null) {
19        // 解凍対象ファイル名を取得する。
20        String fileName = entry.getName();
21        // ディレクトリの場合
22        if (entry.isDirectory()) {
23            // ディレクトリを作成する。
24            Path filePath = Paths.get(this.currentTmpDir + Const.FILE_PATH_SEPARATOR + fileName);
25            Files.createDirectories(filePath);
26        // ファイルの場合
27        } else {
28            // 解凍処理を行う。
29            extract(zis, fileName);
30        }
31    }
32  } catch (Exception e) {
33    LOGGER.error("エラー発生");
34    throw new Exception("エラー発生", e);
35 
36  } finally {
37    if (zis != null) {
38      try {
39        zis.close();
40      } catch (Exception e) {
41        LOGGER.error("エラー発生");
42        throw new Exception("エラー発生", e);
43      }
44    }
45  }
46}
47 
48 * 解凍処理
49 * @param zis 圧縮ストリーム
50 * @param fileName 解凍対象ファイル名
51 */
52private void extract(ZipInputStream zis, String fileName) throws Exception {
53 
54  // 出力用のストリームを宣言する。
55  BufferedOutputStream bos = null;
56 
57  try {
58    // 解凍対象ファイルのフルパスを取得する。
59    Path filePath = Paths.get(this.currentTmpDir + Const.FILE_PATH_SEPARATOR + fileName);
60 
61    // 解凍対象ファイルを読み込む。
62    int readSize = 0;
63    byte[] buffer = new byte[1024];
64    bos = new BufferedOutputStream(
65        new FileOutputStream(filePath.toString()), 1024);
66 
67    // 解凍対象ファイルをファイルとして出力する。
68    while ((readSize = zis.read(buffer, 0, buffer.length)) != -1) {
69        bos.write(buffer, 0, readSize);
70    }
71    bos.flush();
72 
73  } finally {
74    if (bos != null) {
75      bos.close();
76    }
77    zis.closeEntry();
78  }
79}
投稿日:

【Java】フォルダ圧縮処理

フォルダ内のファイルを圧縮します。

ソースを表示
印刷SyntaxHighlighterについて
1/**
2 * フォルダ圧縮処理
3 * @param 圧縮対象フォルダ「C:\work\dir」
4 * @param 圧縮ファイル名「C:\work\send_20181104150000.zip」
5 */
6private void dirCompress(String dir, String zipFileName) throws Exception {
7 
8  // 圧縮ストリームオブジェクトを宣言する。
9  ZipOutputStream zos = null;
10 
11  try {
12    // 圧縮ストリームオブジェクトを生成する。
13    zos = ZipOutputStream(
14      new FileOutputStream(
15        new File(zipFileName)), Charset.forName("MS932"));
16 
17    // フォルダ内のファイル一覧を取得する。
18    List<Path> filePahtList = Files.list(Paths.get(dir).collect(Collectors.toList());
19 
20    // ファイル一覧分繰り返す。
21    for (Path filePath : filePathList) {
22      archive(zos, filePath, Paths.get(dir).getFileName().toString() + "\\" + filePath.getFileName().toString());
23    }
24 
25    zos.closeEntry();
26    zos.finish();
27 
28  } catch (Exception e) {
29    LOGGER.error("エラー発生");
30    throw new Exception("エラー発生", e);
31 
32  } finally {
33    if (zos != null) {
34      try {
35        zos.close();
36      } catch (Exception e) {
37        LOGGER.error("エラー発生");
38        throw new Exception("エラー発生", e);
39      }
40    }
41  }
42}
43 
44 * 圧縮処理
45 * @param zos 圧縮ストリーム
46 * @param filePath 圧縮対象ファイルパス
47 * @param fileName 圧縮対象ファイル名
48 */
49private void archive(ZipOutputStream zos, Path filePath, String fileName) throws Exception {
50 
51  // 圧縮対象ファイルの読込ストリームを宣言する。
52  BufferedInputStream bis = null;
53 
54  try {
55    // zipエントリを作成する。
56    zos.putNextEntry(new ZipEntry(fileName));
57 
58    // ファイルの場合
59    if (! Files.isDirectory(filePath)) {
60      // 圧縮対象ファイルを読み込む。
61      bis = new BufferedInputStream(new FileInputStream(filePath.toString()));
62 
63      // 圧縮対象ファイルをzipファイルに出力する。
64      int readSize = 0;
65      byte[] buffer = new byte[1024];
66      while ((readSize = bis.read(buffer, 0, buffer.length)) != -1) {
67        zos.write(buffer, 0, readSize);
68      }
69    }
70  } finally {
71    if (bis != null) {
72      bis.close();
73    }
74    zos.closeEntry();
75  }
76}
投稿日:

【Java】画像のマスク処理

画像に対して個人情報等をマスクする際に利用します。

ソースを表示
印刷SyntaxHighlighterについて
1private void imageMaskBlack(String imageFile) thorws Exception {
2 
3  // 変数を宣言する。
4  BufferedImage bimg = null;
5  Graphics graphics = null;
6  ImageReader jpgReader = null;
7  ImageWriter jpgWriter = null;
8 
9  try {
10    // イメージファイルを読み込む。(ImageIO.readは利用しない方針)
11    jpgReader ImageIO.getImageReadersByFormatName("jpeg").next();
12    jpgReader.setInput(ImageIO.createImageInputStream(new File(imageFile)));
13    bimg = jpgReader.read(0);
14 
15    // Graphicsオブジェクトを取得する。
16    graphics = bimg.getGraphics();
17    graphics.setColor(Color.BLACK);
18    // X座標、Y座標、幅、高さを指定し黒色でマスクする。
19    // 画像の左上がX座標:0、Y座標:0
20    graphics.fillRect(100, 50, 100, 100);
21    graphics.drawImage(bimg, 0, 0, null);
22 
23    // 品質と解像度指定
24    // イメージを書き込むため、ImageIOからjpg用のImageWriterを取得する。
25    jpgWriter = ImageIO.getImageWritersByFormatName("jpeg").next();
26 
27    // ImageWriterのパラメータ設定
28    // パラメータを取得する。
29    JPEGImageWriteParam jpgWriteParam = (JPEGImageWriteParam)jpgWriter.getDefaultWriteParam();
30    // パラメータに品質指定を行うモードを指定する。
31    jpgWriteParam.setCompressionMode(ImageWriteParam.MODE_EXPLICIT);
32    // パラメータに品質を指定する。(0.0f～1.0f)
33    jpgWriteParam.setCompressionQuality(0.5f);
34 
35    // ImageWriterのメタデータの設定
36    // メタデータを取得する。
37    IIOMetadata imageMeta = jpgWriter.getDefaultImageMetadata(new ImageTypeSpecifier(bimg), jpgWriteParam);
38    // メタデータからXMLのツリー構造を取得する。
39    Element tree = (Element)imageMeta.getAsTree("javax_imageio_jpeg_image_1.0");
40    // ツリー構造から要素「JFIF」を取得する。
41    Element jfif = (Element)tree.getElementsByTagName("app0JFIF").item(0);
42    //DPI指定を行うモードを指定する。
43    jfif.setAttribute("resUnits", "1");
44    // X座標は300dpiを指定する。
45    jfif.setAttribute("Xdensity", 300);
46    // Y座標は300dpiを指定する。
47    jfif.setAttribute("Ydensity", 300);
48    // メタデータにツリー構造を設定し直す。
49    imageMeta.setFromTree("javax_imageio_jpeg_image_1,0", tree);
50 
51    // これまでに行った設定を元にイメージファイルを出力する。(ImageIO.writeは利用しない方針)
52    jpgWriter.setOutput(ImageIO.createImageOutputStream(new File(imageFile)));
53    jpgWriter.write(null, new IIOImage(bimg, null, imageMeta), jpgWriteParam);
54 
55  } finally {
56    if (grahics != null) {
57      graphics.dispose();
58      graphics = null;
59    }
60    if (jpgWriter != null) {
61      jpgWriter.reset();
62      jpgWriter = null;
63    }
64    if (jpgReader != null) {
65      jpgReader.reset();
66      jpgReader = null;
67    }
68    if (bimg != null) {
69      bimg.flush();
70      bimg = null;
71    }
72  }
73}
投稿日:

【Java】ビルドを自動で行う

build.xmlをantでビルドする作業を自動で行います。

  • 起動バッチ

    ソースを表示
    印刷SyntaxHighlighterについて
    1@echo off
    2set ANT_HOME=D:/Product/apache-ant-1.10.1
    3set BUILD_FILE=build.xml
    4set TARGET=destcopy
    5set PROJECT_HOME=D:/Product/APP/
    6cd %PROJECT_HOME%
    7if %ERRORLEVEL%==0 (
    8  echo ビルドを開始します。
    9  echo ログは%PROJECT_HOME%/build.logに出力しています。
    10  call %ANT_HOME%/bin/ant -f %BUILD_FILE% -l build.log %TARGET%
    11)
    12if %ERRORLEVEL%==0 (
    13  echo ビルドを終了します。
    14) else (
    15  echo エラーが発生しています。ログを確認してください。
    16)
    17pause
  • build.xml

    ソースを表示
    印刷SyntaxHighlighterについて
    1<?xml version"1.0" encoding="UTF-8"?>
    2<project name="APP-TEST" basedir="." default="destcopy">
    3 
    4  <!-- classpath指定 -->
    5  <path id="classpath">
    6    <fileset dir="./lib">
    7      <include name="*.jar" />
    8    </fileset>
    9    <fileset dir="./WebContent/WEB-INF/lib">
    10      <include name="*.jar" />
    11    </fileset>
    12 
    13  <!-- 初期化 -->
    14  <target name="clean" description="コンパイル済のclassファイルとjarファイルを削除">
    15    <delete dir="./dest" />
    16    <delete dir="./bin" />
    17  </target>
    18 
    19  <!-- プロジェクトコンパイル -->
    20  <target name="compile" depends="clean" description="コンパイル開始">
    21    <mkdir dir="./bin" />
    22    <javac debug="on" fork="true" destdir="./bin" srcdir="./src" classpathref="classpath" deprecation="on" encoding="UTF-8" includeantruntime="flase">
    23      <compilerarg value="-Xlint:unchecked" />
    24    </javac>
    25  </target>
    26 
    27  <!-- jarファイル作成 -->
    28  <target name="destcopy" depends="compile" description="jarファイル作成開始">
    29    <mkdir dir="./dest" />
    30    <copy toDir="./dest/standalone/deployments/APP-TEST.war">
    31      <fileset dir="./WebContent" />
    32    </copy>
    33    <copy toDir="./dest/standalone/configuration">
    34      <fileset dir="./jbossconfiguration" />
    35    </copy>
    36    <copy toDir="./dest/standalone/deployments/APP-TEST.war/WEB-INF/classes">
    37      <fileset dir="./bin/" />
    38    </copy>
    39    <touch file="./dest/standalone/deployments/APP-TEST.war.dodeploy" />
    40  </target>
    41</project>
投稿日:

【Java】指定日付の月末月初を求める

Java8のLocalDateクラスを利用して指定日付の月末月初を求めます。

ソースを表示
印刷SyntaxHighlighterについて
1// フォーマット
2DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyyMMdd");
3// 月初
4LocalDate ldFirst = LocalDate.parse("20181015", dtf).withDayOfMonth(1);
5// 月末
6LocalDate ldLast = LocalDate.parse("20181015", dtf).withDayOfMonth(1).plusMonth(1).minusDays(1);
7 
8// 文字列変換
9String strFirst = dtf.format(ldFirst);
10String strLast = dtf.format(ldLast);
投稿日:

【Java】マルチスレッド処理

Javaのスレッド処理に関するメモ。
呼び出す側だけを変更すれば対応可能です。
今回の例では1ファイルをタスクに渡しているので、
大量ファイルで1ファイル内のレコード量が少ない時に効果が出ます。
1ファイルで1ファイル内のレコード量が多い場合、タスクに渡す単位を考えた方が良いです。

  • 呼び出す側
    ソースを表示
    印刷SyntaxHighlighterについて
    1public static void main(String[] args) {
    2    Z_Thread main = new Z_Thread();
    3    // スレッド管理サービスを生成する。
    4    ExecutorService multiExecutor = Executors.newFixedThreadPool(2);
    5    main.executeMultiTask(multiExecutor);
    6    // スレッドを終了する。
    7    multiExecutor.shutdown();
    8}
    ソースを表示
    印刷SyntaxHighlighterについて
    1private void executeMultiTask(ExecutorService serviceExecutor) {
    2    // 戻り値を定義する。
    3    List<Future<Long>> futures = new ArrayList<Future<Long>>();
    4    Future<Long> future = null;
    5    try {
    6        String fileDir = "D:\\";
    7        String fileName = "";
    8        // 指定ディレクトリの「*.txt」の一覧を取得する。
    9        Path path = Paths.get(fileDir);
    10        try (DirectoryStream<Path> directoryStream = Files.newDirectoryStream(path, "*.txt")) {
    11            // 指定ディレクトリの「*.txt」数分繰り返す。
    12            for (Path p : directoryStream) {
    13                // ファイル名を取得する。
    14                fileName = p.getFileName().toString();
    15                // 取得したファイル名をタスクに登録する。
    16                // タスクはCallableを利用することで戻り値と例外を受け取れるようにする。
    17                // タスクはRunnableを利用すると戻り値と例外は受け取れない。
    18                Future<Long> future = serviceExecutor.submit(new CallableTest(fileDir, fileName));
    19                futures.add(future);
    20            }
    21        } catch (IOException e) {
    22            System.out.println("IO例外");
    23        }
    24        // 結果を順次取得する。
    25        for (Future<Long> futureResult : futures) {
    26            Long result = futureResult.get(20000, TimeUnit.MILLISECONDS);
    27            System.out.println("結果：" + result + "：スレッドの結果を受け取りました。");
    28        }
    29    } catch (InterruptedException e){
    30        System.out.println("割り込み例外");
    31    } catch (ExecutionException e) {
    32        System.out.println("タスクの中で例外発生");
    33    } catch (TimeoutException e) {
    34        System.out.println("タイムアウト例外発生");
    35    } catch (Exception e) {
    36        System.out.println("何かの例外発生")
    37    } finally {
    38        future.cancel(true);
    39    }
    40}
投稿日:

【Java】シングルスレッド処理

Javaのスレッド処理に関するメモ。
JDK1.4ではThreadを利用していたが、JDK1.5以降はExecutorServiceを利用する。

  • 呼び出す側
    ソースを表示
    印刷SyntaxHighlighterについて
    1public static void main(String[] args) {
    2    Z_Thread main = new Z_Thread();
    3    // スレッド管理サービスを生成する。
    4    ExecutorService singleExecutor = Executors.newSingleThreadExecutor();
    5    main.executeSingleTask(singleExecutor);
    6    // スレッドを終了する。
    7    singleExecutor.shutdown();
    8}
    ソースを表示
    印刷SyntaxHighlighterについて
    1private void executeSingleTask(ExecutorService serviceExecutor) {
    2    // 戻り値を定義する。
    3    Future<Long> future = null;
    4    try {
    5        String fileDir = "D:\\";
    6        String fileName = "";
    7        // 指定ディレクトリの「*.txt」の一覧を取得する。
    8        Path path = Paths.get(fileDir);
    9        try (DirectoryStream<Path> directoryStream = Files.newDirectoryStream(path, "*.txt")) {
    10            // 指定ディレクトリの「*.txt」数分繰り返す。
    11            for (Path p : directoryStream) {
    12                // ファイル名を取得する。
    13                fileName = p.getFileName().toString();
    14                // 取得したファイル名をタスクに登録する。
    15                // タスクはCallableを利用することで戻り値と例外を受け取れるようにする。
    16                // タスクはRunnableを利用すると戻り値と例外は受け取れない。
    17                future = serviceExecutor.submit(new CallableTest(fileDir, fileName));
    18                // Futureクラスのgetメソッドを呼び出すと呼び出し側は結果が返ってくるまで処理を止める。
    19                // 20秒を過ぎるとタイム例外が返ってくる。
    20                Long result = future.get(20000, TimeUnit.MILLISECONDS);
    21                System.out.println("結果：" + result + "：スレッドの結果を受け取りました。");
    22            }
    23        }
    24    } catch (InterruptedException e){
    25        System.out.println("割り込み例外");
    26    } catch (ExecutionException e) {
    27        System.out.println("タスクの中で例外発生");
    28    } catch (TimeoutException e) {
    29        System.out.println("タイムアウト例外発生");
    30    } catch (Exception e) {
    31        System.out.println("何かの例外発生");
    32    } finally {
    33        future.cancel(true);
    34    }
    35}
  • 呼び出される側(タスク)(Callableを利用する)
    ソースを表示
    印刷SyntaxHighlighterについて
    1private String fileDir = "";
    2private String fileName = "";
    3 
    4public CallableTest(String fileDir, String fileName) {
    5    this.fileDir = fileDir;
    6    this.fileName = fileName;
    7}
    8 
    9public Long call() throws Exception {
    10    try {
    11        System.out.println(Thread.currentThread().getId() + "：スレッド処理開始");
    12        if (Thread.currentThread().isInterrupted()) {
    13            System.out.println("スレッドに割り込みありました。");
    14            throw new InterruptedException("割り込み例外");
    15        }
    16 
    17        // 何かの処理を想定
    18        Thread.sleep(10000);
    19        // コンストラクタで指定したファイルの内容を読み取り表示する。
    20        List<String> line = Files.readAllLines(Paths.get(fileDir, fileName), Charset.forName("UTF-8"));
    21        System.out.println(Thread.currentThread().getId() + "：" + fileName + "の内容を表示");
    22        for (String str : line) {
    23            System.out.println(str);
    24        }
    25    } catch(Exception e){
    26        System.out.println(Thread.currentThread().getId() + "エラー検知");
    27        throw e;
    28    } finally {
    29        System.out.println(Thread.currentThread().getId() + "：スレッド処理終了");
    30    }
    31    return Thread.currentThread().getId();
    32}