非推奨となっていたJava.facesをCDIにリプレイスしてみた

投稿日時: 2022年12月6日投稿者: bokusui

　7年前くらいに作ったWebLogicで動かしているアプリがあるのですが、Java.faces系のDI実装がだいぶ前から非推奨となっていたので、どこかで対応しないとなあ～と思っていてから数年経ちましたが、時間が取れたのでCDI実装に置き換えてみました。

　まず、簡単なところでは、javax.faces.bean.RequestScoped 等のスコープ指定を CDIのjavax.enterprise.context.RequestScoped に、
javax.faces.bean.ManagedBean を javax.inject.Named に
この辺りは単純にimportするライブラリを変更するだけです。ただし、@ViewScopedと@SessionScopedについては、Serializableを実装する必要があるようです。

//import javax.faces.bean.ManagedBean;
//import javax.faces.bean.SessionScoped;
import javax.enterprise.context.SessionScoped;
import javax.inject.Named;

//@ManagedBean(name = "xxxController")
@Named(value = "xxxController")
@SessionScoped
public class XXXController implements Serializable {

以下略

//import javax.faces.bean.ManagedBean;

//import javax.faces.bean.SessionScoped;

import javax.enterprise.context.SessionScoped;

import javax.inject.Named;

//@ManagedBean(name = "xxxController")

@Named(value = "xxxController")

@SessionScoped

public class XXXController implements Serializable {

以下略

　次に、javax.faces.bean.ManagedProperty ですが、こちらは２パターンの対応が必要となり、@ManagedPropertyでDIしている箇所は、@Injectと@Namedに置き換えるだけです。

public class UserService implements Serializable {

//	@ManagedProperty("#{userDto}")
	@Inject
	@Named("userDto")
	UserDto user;"

以下略

public class UserService implements Serializable {

// @ManagedProperty("#{userDto}")

@Inject

@Named("userDto")

UserDto user;"

以下略

　ManagedPropertyの別パターンで、今回対象のアプリではxhtmlからのPOSTデータ授受に使用していたのですが、javax.faces.annotation.ManagedProperty に置き換えても動かなかったので、下記のようにFacesContext経由でデータを受け取るようにしました。

public class UserController{

//    @ManagedProperty(value=""#{param.data}"")
//    private User user;

    public String editUser(){
        FacesContext context = FacesContext.getCurrentInstance();
        User user = (User) context.getApplication().evaluateExpressionGet(context,"#{data}", User.class);

以下略

public class UserController{

// @ManagedProperty(value=""#{param.data}"")

// private User user;

public String editUser(){

FacesContext context = FacesContext.getCurrentInstance();

User user = (User) context.getApplication().evaluateExpressionGet(context,"#{data}", User.class);

以下略

　最後に、アプリでは共有したいセッション情報等を保持する為に、@ApplicationScopedをeager指定してアプリ開始時に生成していたのですが、CDI-APIの方では存在せず、初回コール時のタイミングで生成されるようです。

//import javax.faces.bean.ApplicationScoped;
//import javax.faces.bean.ManagedBean;
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Named;

//@ManagedBean(name="XXX",eager=true)
@Named(value = "XXX")
@ApplicationScoped
public class XXXManager {

以下略

//import javax.faces.bean.ApplicationScoped;

//import javax.faces.bean.ManagedBean;

import javax.enterprise.context.ApplicationScoped;

import javax.inject.Named;

//@ManagedBean(name="XXX",eager=true)

@Named(value = "XXX")

@ApplicationScoped

public class XXXManager {

以下略

　参照している箇所も見直しが必要で結果的に下記のように置き換えました。

//        XXXManager mgr = (XXXManager) req.getSession().getServletContext().getAttribute("XXX");
        XXXManager mgr = CDI.current().select(XXXManager.class).get();
        if(mgr ==  null){
            //生成前の時
        }

// XXXManager mgr = (XXXManager) req.getSession().getServletContext().getAttribute("XXX");

XXXManager mgr = CDI.current().select(XXXManager.class).get();

if(mgr == null){

//生成前の時

}

　動作は一通り確認しましたが、何か機能が追加された訳でもなく、置き換え前でも動きは変わらないので、いつリリース出来るかなあ。。

いつのまにかojdbcがMaven Repositoryに公開されていた

投稿日時: 2022年7月30日投稿者: bokusui

　現在、数年前に作ったOracleDBを使うアプリの改修しているのですが、前まではOracleのリポジトリ(maven.oracle.com)からしかダウンロードできなかったojdbcが、いつのまにかMaven Repositoryからダウンロードできるようになってました。

　しかも、Oracleのリポジトリがどこかのタイミングで更新を止めているのか、Maven Repositoryから取得出来るライブラリの方が新しいバージョンを取得出来る状態になっているようです。自前のリポジトリ運用を諦めたのでしょうか？

　Oracleのリポジトリでは、groupIdがcom.oracle.jdbcとMavenと微妙に違っているので、気が付かないとOracleのリポジトリにあるライブラリが最新かと勘違いしてしまいます。

<!-- https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8 -->
<dependency>
    <groupId>com.oracle.database.jdbc</groupId>
    <artifactId>ojdbc8</artifactId>
    <version>19.15.0.0.1</version>
</dependency>

<groupId>com.oracle.database.jdbc</groupId>

<artifactId>ojdbc8</artifactId>

</dependency>

　Weblogic等、DB周りのライブラリ以外は従来のままっぽいです。

SpringBootを2.0.1.RELEASEから2.6.6にバージョンアップしてみた

投稿日時: 2022年4月15日投稿者: bokusui

数年前に他で作られたものを引き継いで担当しているSpringBootアプリがあるのですが、dependency-checkを実行するとライブラリに多数の脆弱性がある事が判明。

[ERROR] dom4j-1.6.1.jar: CVE-2020-10683(9.8)
[ERROR] hibernate-core-5.2.16.Final.jar: CVE-2019-14900(6.5), CVE-2020-25638(7.4)
[ERROR] hibernate-validator-6.0.9.Final.jar: CVE-2019-10219(6.1), CVE-2020-10693(5.3)
略

[ERROR] dom4j-1.6.1.jar: CVE-2020-10683(9.8)

[ERROR] hibernate-core-5.2.16.Final.jar: CVE-2019-14900(6.5), CVE-2020-25638(7.4)

[ERROR] hibernate-validator-6.0.9.Final.jar: CVE-2019-10219(6.1), CVE-2020-10693(5.3)

略

対応の時間が取れそうなので、spring-boot-starterを対応開始時点最新だった2.6.4へ一気に上げてみる事にしました。今回対象のアプリではごく一部だけコード変更が必要でしたが、それを書き直して実行してみると、、起動に失敗しているようです。

***************************
APPLICATION FAILED TO START
***************************
Description:
The dependencies of some of the beans in the application context form a cycle:
   processorLookupService (field private jp.esoro.automation.application.impl.xxxx)
      ↓
   monitoringAlert (field private jp.esoro.automation.application.ApplicationEvents xxxx)
┌─────┐
|  applicationEventsImpl (field private jp.esoro.automation.application.NotificationLookupService xxxx)
↑     ↓
|  notificationLookupService (field jp.esoro.automation.application.impl.ChangeNotification xxxx)
↑     ↓
|  changeNotification (field private jp.esoro.automation.application.ApplicationEvents xxxx)
└─────┘
Action:
Relying upon circular references is discouraged and they are prohibited by default. Update your application to remove the dependency cycle between beans. As a last resort, it may be possible to break the cycle automatically by setting spring.main.allow-circular-references to true.

***************************

APPLICATION FAILED TO START

***************************

Description:

The dependencies of some of the beans in the application context form a cycle:

processorLookupService (field private jp.esoro.automation.application.impl.xxxx)

↓

monitoringAlert (field private jp.esoro.automation.application.ApplicationEvents xxxx)

┌─────┐

| applicationEventsImpl (field private jp.esoro.automation.application.NotificationLookupService xxxx)

↑ ↓

| notificationLookupService (field jp.esoro.automation.application.impl.ChangeNotification xxxx)

↑ ↓

| changeNotification (field private jp.esoro.automation.application.ApplicationEvents xxxx)

└─────┘

Action:

Relying upon circular references is discouraged and they are prohibited by default. Update your application to remove the dependency cycle between beans. As a last resort, it may be possible to break the cycle automatically by setting spring.main.allow-circular-references to true.

下記にも出てましたが、メッセージの図が示している通り循環参照をしているようです。

qiita.com

https://qiita.com/rhirabay/items/c3fe7cd7faee9f35ab2c

該当箇所のコードを読み、そのままで問題無い事を確認した上でメッセージの通りにapplication.ymlに設定を追加します。

  spring:
    main:
      allow-circular-references: true

spring:

main:

allow-circular-references: true

稼働確認をしていくと数か所の動作に問題がありましたが、基本的にはライブラリ間のバージョン不一致によるものだったので、使用ライブラリの依存を整理してバージョンを調整。

対応が殆ど終わったと思ったら、Springの脆弱性「Spring4Shell」が見つかり、実行環境的にはJava1.8なので影響は無いのですが、最新の2.6.6にして再度稼働確認し一段落。

FileInputStreamでは日本語のファイル名が見つからない

投稿日時: 2022年3月29日投稿者: bokusui

emlファイルからメールをいろいろ加工するようなブツを作っているのですが、日本語が含まれるファイルの場合、問題になる事が判明。

String filePath = "/var/lib/apl/aaa/faile/日本語emlファイル.eml";
MimeMessage msg = new MimeMessage(null, new FileInputStream(filePath));

1 2	String filePath = "/var/lib/apl/aaa/faile/日本語emlファイル.eml"; MimeMessage msg = new MimeMessage(null, new FileInputStream(filePath));

開発環境のWindowsでは特に問題ありませんでしたが、Linux環境で実行するとファイルが見つかりませんでエラーになるんですね。。

こちらの下の方を参考に、nio仕様に変えたら問題は解消しました。環境依存でしょうか、特にJVM引数は必要なかったです。

String filePath = "/var/lib/apl/aaa/faile/日本語emlファイル.eml";
Path file = Paths.get(filePath);
if(file.toFile().exists()){
   MimeMessage msg = new MimeMessage(null, Files.newInputStream(file)); 
}

String filePath = "/var/lib/apl/aaa/faile/日本語emlファイル.eml";

Path file = Paths.get(filePath);

if(file.toFile().exists()){

MimeMessage msg = new MimeMessage(null, Files.newInputStream(file));

}

今の時代、Javaのファイル処理はnioに統一した方がよさそうですね。

maven dependency-checkを試してみた

投稿日時: 2022年2月28日投稿者: bokusui

　前回から続きのテーマですが、使用しているライブラリのバージョンアップについて、せめて脆弱性が発覚しているものだけでも対応した方がよいかと思い、探していたらぴったりな下記Mavenプラグインの存在を発見

jeremylong.github.io

dependency-check-maven – Usage

https://jeremylong.github.io/DependencyCheck/dependency-check-maven/index.html

　現在、数年前に作ったWeblogicアプリの変更をしているので、これを試してみます。

mvn dependency-check:check

　どうもWeblogicに依存しているライブラリで結構な数脆弱性が見つかっているようです。これは実行環境でパッチを当てて対応するんだろうなという事で、チェックから無視するようにします。

        <plugin>
            <groupId>org.owasp</groupId>
            <artifactId>dependency-check-maven</artifactId>
            <configuration>
                <skipProvidedScope>true</skipProvidedScope>
                <skipRuntimeScope>true</skipRuntimeScope>
            </configuration>
        </plugin>

<groupId>org.owasp</groupId>

<artifactId>dependency-check-maven</artifactId>

</configuration>

</plugin>

　それ以外のライブラリでバージョンアップすると現状のコードでは動作しなくなる箇所もあったのですが、CVEのスコア的に今回対象外としました。

ライブラリのバージョンアップについて

投稿日時: 2021年12月29日投稿者: bokusui

　年末に近いので変更リリースとかは年明け以降に、という事にしていましたが、急遽lo4j2にリモートコード実行の脆弱性が発覚したので、使用しているJavaアプリケーションを洗い出して最新ライブラリへ入れ替えの対応をしていました。

　log4j2について人知れず存在していた便利機能が今になって仇となったような感じですが、影響範囲はログ出力だけで、対応もライブラリの置き換えだけなので、実際の作業自体は大したことはありません。最初の脆弱性発覚後バージョンアップは計３回となり、一度脆弱性が指摘されたものに対しては、連鎖的に問題が指摘されやすくなっているようです。とはいえ、オープンソースとして利用させてもらっているのでメンテナンスをしている方々に感謝ですね。

　今回のようにセキュリティ問題として大々的にアナウンスされたものは即対応が必須となりますが、数年前から稼働させているようなアプリでは、使用しているライブラリがバージョンアップされていても、大抵は従来のままという事が多いような気がします。

　明確に運用方針を挙げている組織であれば、ハードやOS、ミドルウェア、言語についての、特にセキュリティパッチについては適切に対処されていると思いますが、アプリで使用しているライブラリやフレームワークまではあまり手を付けていないように思います。

　筆者の場合、基本的に一人で面倒を見ているようなものですが、セキュリティ対応以外でのライブラリのバージョンアップは正直考えたことも無かったです。今回メンテナンス対象となったアプリでいえば開発当時のlog4j2 2.5を使ってそのまま5年以上が経過、今回の脆弱性発覚でやっと2.17に上げたところです。

　稼働中のアプリが使用しているライブラリのバージョン管理はやった方がよいとは思うのですが、情報収集から対応、稼働確認等、かなりの運用コストが掛かり、かつ機能が増える訳でも無いので、やるとしても何かしら追加の業務要件が発生した時の次いでにバージョンをチェックして、変更するか検討するくらいですかね。

Java mail で Unknown encoding 発生

投稿日時: 2021年7月27日投稿者: bokusui

Javaで書いた、いろんなメールを受信して業務の一部を自動化するツールを何年も運用しているのですが、見慣れないエラーが出ていたので確認すると、

java.io.IOException: Unknown encoding: 8-bit at javax.mail.internet.MimePartDataSource.getInputStream(MimePartDataSource.java:116) ~[jar:rsrc:javax.mail-1.6.2.jar!/:?] at com.sun.mail.handlers.text_plain.getContent(text_plain.java:83) ~[jar:rsrc:javax.mail-1.6.2.jar!/:?] at javax.activation.DataSourceDataContentHandler.getContent(DataHandler.java:795) ~[?:1.8.0_275] at javax.activation.DataHandler.getContent(DataHandler.java:542) ~[?:1.8.0_275] at javax.mail.internet.MimeBodyPart.getContent(MimeBodyPart.java:683) ~[jar:rsrc:javax.mail-1.6.2.jar!/:?] 略 Caused by: javax.mail.MessagingException: Unknown encoding: 8-bit at javax.mail.internet.MimeUtility.decode(MimeUtility.java:405) ~[jar:rsrc:javax.mail-1.6.2.jar!/:?] at javax.mail.internet.MimePartDataSource.getInputStream(MimePartDataSource.java:109) ~[jar:rsrc:javax.mail-1.6.2.jar!/:?] ... 13 more

とログに吐き出されています。

String body = (String) mailpart.getContent();

と、コンテンツタイプがtextのメールパートを本文として文字列にキャストしたタイミングで例外に飛んでます。

該当のメールをEMLファイルでメールの中身を確認すると
Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: 8-bit
となっています。

通常は
Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: 8bit
だったり、

Content-Type: text/plain; charset="ISO-2022-JP" Content-Transfer-Encoding: 7bit
のようです。

Javamailでは、8bitでなく8-bitだと例外になるのか。。。
仕方ないので、キャストに失敗した後に強制的に8bitに置き換えて本文を読み取るようにしました。

part.setHeader( "Content-Transfer-Encoding", "8bit"); String body = (String) p.getContent();

メールの受信処理は、送信側次第でイレギュラーなメールが発生するので面倒です。。

apache.commons.csvでinvalid char between encapsulated token and delimiter

投稿日時: 2021年4月20日投稿者: bokusui

　だいぶ前に作ったapache.commons.csvとapache.poiを使ったCSVファイルからエクセル出力処理で、

java.io.IOException: (line 3) invalid char between encapsulated token and delimiter

　が発生していました。原因は、ダブルクォーテーションで括っているデータ項目の中にダブルクォーテーションが混ざっていたからなのですが、データを出力する側で対処するのが出来そうにないので、CSVファイルを読み込む所で何とかならんものかと検討。
　
　CSVファイルを読む箇所は下記のようにInputStreamが渡され、CSVRecordリストを取得して色々やるという内容です。

    public static int parseCSV(InputStream input){
	BufferedReader in = new BufferedReader(new InputStreamReader(input));

	CSVParser parser = CSVFormat
	        .EXCEL
	        .withIgnoreEmptyLines(true)
	        .withIgnoreSurroundingSpaces(false)
	        .withRecordSeparator(System.getProperty("line.separator"))
	        .withDelimiter(',')
	        .withEscape('\\')
	        .withQuote('"')
	        .parse(in);
	List<CSVRecord> recordList = parser.getRecords();

//以下、略

public static int parseCSV(InputStream input){

BufferedReader in = new BufferedReader(new InputStreamReader(input));

CSVParser parser = CSVFormat

.EXCEL

.withIgnoreEmptyLines(true)

.withIgnoreSurroundingSpaces(false)

.withRecordSeparator(System.getProperty("line.separator"))

.withDelimiter(',')

.withEscape('\\')

.withQuote('"')

.parse(in);

List<CSVRecord> recordList = parser.getRecords();

//以下、略

　殆どの場合で問題は発生しないので、出来れば失敗した場合のみリトライ出来ればいいかなと、データ内に混ざりこんだダブルクォーテーションをエスケープするようにしてみます。正規表現での変換を３段階かますことで、一部ケース（データ内にカンマとダブルクォーテーションが連続した場合）は問題ですが、今回はまあこの位で。。

　次に失敗した後のフォローとなるので、読込が進んでしまっているInputStreamを何とかしなければなりません。結局、IOUtilsでテンポラリファイルにコピーしてから読み込むようにしました。

    public static int parseCSV(InputStream input){
//	BufferedReader in = new BufferedReader(new InputStreamReader(input));

        File fstream = File.createTempFile("csv",".txt");
        FileOutputStream out = new FileOutputStream(fstream);
        IOUtils.copy(input, out);
        out.close();

        List<CSVRecord> recordList;

        try(BufferedInputStream bf = new BufferedInputStream(new　FileInputStream(fstream.getAbsoluteFile()));
            BufferedReader in = new BufferedReader(new InputStreamReader(bf));)
        {
            CSVParser parser = CSVFormat
                    .EXCEL
                    .withIgnoreEmptyLines(true)
                    .withIgnoreSurroundingSpaces(false)
                    .withRecordSeparator(System.getProperty("line.separator"))
                    .withDelimiter(',')
                    .withEscape('\\')
                    .withQuote('"')
                    .parse(in);

            recordList = parser.getRecords();
        }
        catch(Exception e){
            logger.error("retry parse tmpfile:" + fstream.getAbsoluteFile(),e );
            BufferedInputStream bf = new BufferedInputStream(new FileInputStream(fstream.getAbsoluteFile()));
            BufferedReader in = new BufferedReader(new InputStreamReader(bf,"UTF-8"));
            StringBuilder sb = new StringBuilder();
            String line;
            while ((line = in.readLine()) != null) {
                line.replaceAll("\\\\", "");
                line = line.replaceAll("(?!(^|,|\",))\"(?!$|\")","\\\\\"");
                line = line.replaceAll(",\\\\\"",",\"");
                sb.append(line+System.getProperty("line.separator"));
            }
            CSVParser parser = CSVFormat
                    .EXCEL
                    .withIgnoreEmptyLines(true)
                    .withIgnoreSurroundingSpaces(false)
                    .withRecordSeparator(System.getProperty("line.separator"))
                    .withDelimiter(',')
                    .withEscape('\\')
                    .withQuote('"')
                    .parse(new StringReader(sb.toString()));

            recordList = parser.getRecords();
            bf.close();
            in.close();
        }
        fstream.deleteOnExit();
//以下、略

public static int parseCSV(InputStream input){

// BufferedReader in = new BufferedReader(new InputStreamReader(input));

File fstream = File.createTempFile("csv",".txt");

FileOutputStream out = new FileOutputStream(fstream);

IOUtils.copy(input, out);

out.close();

List<CSVRecord> recordList;

try(BufferedInputStream bf = new BufferedInputStream(new　FileInputStream(fstream.getAbsoluteFile()));

BufferedReader in = new BufferedReader(new InputStreamReader(bf));)

{

CSVParser parser = CSVFormat

.EXCEL

.withIgnoreEmptyLines(true)

.withIgnoreSurroundingSpaces(false)

.withRecordSeparator(System.getProperty("line.separator"))

.withDelimiter(',')

.withEscape('\\')

.withQuote('"')

.parse(in);

recordList = parser.getRecords();

}

catch(Exception e){

logger.error("retry parse tmpfile:" + fstream.getAbsoluteFile(),e );

BufferedInputStream bf = new BufferedInputStream(new FileInputStream(fstream.getAbsoluteFile()));

BufferedReader in = new BufferedReader(new InputStreamReader(bf,"UTF-8"));

StringBuilder sb = new StringBuilder();

String line;

while ((line = in.readLine()) != null) {

line.replaceAll("\\\\", "");

line = line.replaceAll("(?!(^|,|\",))\"(?!$|\")","\\\\\"");

line = line.replaceAll(",\\\\\"",",\"");

sb.append(line+System.getProperty("line.separator"));

}

CSVParser parser = CSVFormat

.EXCEL

.withIgnoreEmptyLines(true)

.withIgnoreSurroundingSpaces(false)

.withRecordSeparator(System.getProperty("line.separator"))

.withDelimiter(',')

.withEscape('\\')

.withQuote('"')

.parse(new StringReader(sb.toString()));

recordList = parser.getRecords();

bf.close();

in.close();

}

fstream.deleteOnExit();

//以下、略

JavaMailメール送信でSMTPサーバを指定するもlocalhostへ接続

投稿日時: 2021年3月13日投稿者: bokusui

　メール送受信をする処理が動いているサーバを別のインフラに移動したいという事で、移行作業し稼働させたところ、メール送信が出来なくなっている事が判明。

　正確には、メール送信処理は複数あり、単純なJavaアプリとして稼働しているプロセスでは問題が無く、SpringbootでWebサービスとして稼働している処理のみが問題となっています。どちらも元のサーバ上では何ら問題なく動作していました。新環境ではJavaアプリのテストはしてましたが、問題無かったのでSpringboot側は割愛してしまいました。なお、Javaアプリと比べて、Springboot側はjavamailのバージョンがSpringbootのバージョンに引きずられて微妙に古い状況(1.6.1)。

　アプリ的には正常終了扱いとなっており、どこでメールが止まっているのかと調べてみると、mail.smtp.hostで指定しているSMTPサーバにはメール送信ログは無く、なぜか移行先サーバー内の/var/log/maillogにログが、、
Network is unreachable で終わっています。

　どうやら指定しているSMTPサーバでなく、localhostに対しメール送信要求をしているようです。

　とりあえず、移行先のサーバでpostfixを稼働させる必要は無いので止めてもらい、メール送信テストを行うと、今度は接続出来ないとアプリ側でエラーになりました。

　どうも、、デフォルト設定がlocalhostで、そちらが優先されているようですね。。

アプリ側が
session = Session.getDefaultInstance(props);
だったので、
session = Session.getInstance(props);
に変えて問題は解消しましたが、どこでデフォルト設定されているのかは不明なままでした。。

こちらが参考になりました。影響は軽微で、ちょっと痛い目にあったという感じです。

Qiita

JavaMailの罠 - Qiita

https://qiita.com/ikemo/items/f2d8077cc35f707ad957

Javaでメールを扱うライブラリとしてJavaMailが有名ですが、設計が古いため、使いにくかったり、いろいろと罠が潜んでいます。その中で自分が痛い目にあったこと、痛い目にあいそうなことを書いておきます(つД`)ノはじめに...

SpringBootでZabbixAPIを使ってみる

投稿日時: 2020年10月28日投稿者: bokusui

　Zabbixの作業を自動化したいという事で、ZabbixAPIを使ってみました。対象のZabbixは3.2とちょっと古めのようですが、API自体はあまりバージョンは気にしなくてよさそうでした。ドキュメントが充実しているので助かります。

認証後、２件のホストを指定してホスト情報を取ってくるテストを書いてみました。

	@Test
	public void testZabbixAPI() throws Exception {
		String zabbixUser = "zabbixuser";
		String zabbixPass = "****";
		String zabbixEndpoint = "http://zabbixserver/zabbix/api_jsonrpc.php";

		//認証
		JSONObject json = new JSONObject();
		json.put("user", zabbixUser);
		json.put("password", zabbixPass);
		json.put("userData", "false");
		
		String token = null;
		ResponseEntity<String> response = Request("user.login", json, zabbixEndpoint, token);
		
	    JsonNode root = new ObjectMapper().readTree(response.getBody());
	    
	    token = root.get("result").get("sessionid").asText();

		//ホスト情報取得
		JSONObject target = new JSONObject();
	    String[] chkTarget = {"server01","server02"};
		JSONArray targetArray = new JSONArray(chkTarget);
	    
    	JSONObject param = new JSONObject();
		param.put("output", new JSONArray(Arrays.asList("hostid","host","name")));
		target.put("host", targetArray);
		param.put("filter", target);

		response = Request("host.get", param, zabbixEndpoint, token);
		ObjectMapper mapper = new ObjectMapper();
		ArrayNode arrayHost = (ArrayNode) mapper.readTree(response.getBody()).path("result");
		
	    System.out.println("hosts: " + arrayHost);
    }
	
	private ResponseEntity<String> Request(String method, JSONObject param, String endPoint, String token) throws Exception {
		JSONObject json = new JSONObject();

		json.put("jsonrpc", "2.0");
        json.put("method", method);
        json.put("params", param);
        json.put("id", 1);
		if(token != null){
            json.put("auth", token);
        }
        HttpMethod httpMethod = HttpMethod.POST;
        
	    HttpEntity <String> entity ;
		HttpHeaders headers = new HttpHeaders();
	    headers.add("Content-Type", "application/json-rpc");
	    headers.add("Accept-Language", "ja");
	    
	    if(param == null){
	    	entity = new HttpEntity <String>(headers);
	    }
	    else{
	    	entity = new HttpEntity <String>(json.toString(), headers);
	    }
	    RestTemplate restTemplate = new RestTemplate();
	    restTemplate.getMessageConverters()
        .add(0, new StringHttpMessageConverter(Charset.forName("UTF-8")));
	    
	    ResponseEntity<String> response = restTemplate.exchange(endPoint, httpMethod, entity, String.class);
	    
		return response;
	}

@Test

public void testZabbixAPI() throws Exception {

String zabbixUser = "zabbixuser";

String zabbixPass = "****";

String zabbixEndpoint = "http://zabbixserver/zabbix/api_jsonrpc.php";

//認証

JSONObject json = new JSONObject();

json.put("user", zabbixUser);

json.put("password", zabbixPass);

json.put("userData", "false");

String token = null;

ResponseEntity<String> response = Request("user.login", json, zabbixEndpoint, token);

JsonNode root = new ObjectMapper().readTree(response.getBody());

token = root.get("result").get("sessionid").asText();

//ホスト情報取得

JSONObject target = new JSONObject();

String[] chkTarget = {"server01","server02"};

JSONArray targetArray = new JSONArray(chkTarget);

JSONObject param = new JSONObject();

param.put("output", new JSONArray(Arrays.asList("hostid","host","name")));

target.put("host", targetArray);

param.put("filter", target);

response = Request("host.get", param, zabbixEndpoint, token);

ObjectMapper mapper = new ObjectMapper();

ArrayNode arrayHost = (ArrayNode) mapper.readTree(response.getBody()).path("result");

System.out.println("hosts: " + arrayHost);

}

private ResponseEntity<String> Request(String method, JSONObject param, String endPoint, String token) throws Exception {

JSONObject json = new JSONObject();

json.put("jsonrpc", "2.0");

json.put("method", method);

json.put("params", param);

json.put("id", 1);

if(token != null){

json.put("auth", token);

}

HttpMethod httpMethod = HttpMethod.POST;

HttpEntity <String> entity ;

HttpHeaders headers = new HttpHeaders();

headers.add("Content-Type", "application/json-rpc");

headers.add("Accept-Language", "ja");

if(param == null){

entity = new HttpEntity <String>(headers);

}

else{

entity = new HttpEntity <String>(json.toString(), headers);

}

RestTemplate restTemplate = new RestTemplate();

restTemplate.getMessageConverters()

.add(0, new StringHttpMessageConverter(Charset.forName("UTF-8")));

ResponseEntity<String> response = restTemplate.exchange(endPoint, httpMethod, entity, String.class);

return response;

}

で、こんな感じで戻ってきます。

hosts: [{“hostid”:”10387″,”host”:”server01″,”name”:”server01_DB”},{“hostid”:”10388″,”host”:”server02″,”name”:”server02_DB”}]

問題無く使えそうなので、要件を整理してから実装してみます。

ESORO system design

「Java」カテゴリーアーカイブ

非推奨となっていたJava.facesをCDIにリプレイスしてみた

いつのまにかojdbcがMaven Repositoryに公開されていた

SpringBootを2.0.1.RELEASEから2.6.6にバージョンアップしてみた

FileInputStreamでは日本語のファイル名が見つからない

maven dependency-checkを試してみた

ライブラリのバージョンアップについて

Java mail で Unknown encoding 発生

apache.commons.csvでinvalid char between encapsulated token and delimiter

JavaMailメール送信でSMTPサーバを指定するもlocalhostへ接続

SpringBootでZabbixAPIを使ってみる

2025年3月
日	月	火	水	木	金	土
						1
2	3	4	5	6	7	8
9	10	11	12	13	14	15
16	17	18	19	20	21	22
23	24	25	26	27	28	29
30	31