デフォルトの設定では、AutoCloseableのclose忘れを教えてもらえないので、教えてもらえるようにInspectionsの設定を変更してあげましょう
下の画像の流れで選択して、 AutoCloseable used without 'try'-with-resources にチェックを入れてあげましょう。
これで、Files#linesだけではなくAutoCloseableのtry-with-resources外での利用やclose忘れを検知できるようになります。
ちゃんと警告出るようになりました！
KtorでThymeleafを試す - しおしおを書いたけど、Ktor 1.2.0(今はまだrc)からThymeleafが使えるようになるみたいなので試してみた。
ktor_version=1.2.0-rc2
ktor-thymeleaf をdependenciesに追加するimplementation "io.ktor:ktor-thymeleaf:$ktor_version"
Thymeleaf をインストールするThymeleaf に関する設定を行う
Thymeleafが使われるようにするためにThymeleafContentを指定する
@Suppress("unused") // Referenced in application.conf fun Application.module() { install(Thymeleaf) { setTemplateResolver(ClassLoaderTemplateResolver().apply { prefix = "templates/" suffix = ".html" characterEncoding = "utf-8" }) } routing { get("/") { call.respond(ThymeleafContent("test", mapOf("users" to Users(listOf(User(1, "user1"), User(2, "user2")))))) } } } class Users(private val users: List<User>) : Iterable<User> { override fun iterator(): Iterator<User> { return users.iterator() } } data class User(val id: Long, val name: String)
<!DOCTYPE html > <html xmlns:th="http://www.thymeleaf.org"> <head> <meta charset="UTF-8"> <title>Title</title> </head> <body> <ul> <!--/*@thymesVar id="users" type="siosio.Users"*/--> <!--/*@thymesVar id="user" type="siosio.User"*/--> <li th:each="user : ${users}" th:text="${user.id + ':' + user.name}"></li> </ul> </body> </html>
動きましたね。
Ktor標準ではThymeleafに対応していなかったので、Thymeleaf使えるかどうか試してみた感じです。
※Ktor1.2以降からThymeleaf機能が追加されたようです→Ktor 1.2.0(rc)で追加されたThymeleaf Featureを試してみた - しおしお
ktor/FreeMarker.kt at master · ktorio/ktor · GitHubを参考に…
やってることは、こんな感じです。
ClassLoaderTemplateResolver の生成と初期設定ThymeleafContent の場合に、Thymeleafを使ったレンダリングimport io.ktor.application.ApplicationCallPipeline import io.ktor.application.ApplicationFeature import io.ktor.http.content.OutgoingContent import io.ktor.response.ApplicationSendPipeline import io.ktor.util.AttributeKey import io.ktor.util.cio.bufferedWriter import kotlinx.coroutines.io.ByteWriteChannel import org.thymeleaf.TemplateEngine import org.thymeleaf.context.Context import org.thymeleaf.templateresolver.ClassLoaderTemplateResolver class ThymeleafContent( val template: String, val model: Map<String, Any>? ) class Thymeleaf(private val engine: TemplateEngine) { companion object Feature : ApplicationFeature<ApplicationCallPipeline, ClassLoaderTemplateResolver, Thymeleaf> { override val key: AttributeKey<Thymeleaf> = AttributeKey("thymeleaf") override fun install(pipeline: ApplicationCallPipeline, configure: ClassLoaderTemplateResolver.() -> Unit): Thymeleaf { val config = ClassLoaderTemplateResolver(Thread.currentThread().contextClassLoader) .apply { prefix = "templates/" suffix = ".html" characterEncoding = "UTF-8" } .apply(configure) val engine = TemplateEngine() engine.setTemplateResolver(config) val feature = Thymeleaf(engine) pipeline.sendPipeline.intercept(ApplicationSendPipeline.Transform) { value -> if (value is ThymeleafContent) { val response = feature.process(value) proceedWith(response) } } return feature } } private fun process(content: ThymeleafContent): ThymeleafOutgoingContent { return ThymeleafOutgoingContent( engine, content ) } private class ThymeleafOutgoingContent( val engine: TemplateEngine, val content: ThymeleafContent ) : OutgoingContent.WriteChannelContent() { override suspend fun writeTo(channel: ByteWriteChannel) { channel.bufferedWriter(Charsets.UTF_8).use { val context = Context().apply { setVariables(content.model) } engine.process(content.template, context, it) } } } }
package siosio import io.ktor.application.Application import io.ktor.application.call import io.ktor.application.install import io.ktor.response.respond import io.ktor.routing.get import io.ktor.routing.routing fun main(args: Array<String>): Unit = io.ktor.server.netty.EngineMain.main(args) @Suppress("unused") // Referenced in application.conf @kotlin.jvm.JvmOverloads fun Application.module(testing: Boolean = false) { install(Thymeleaf) routing { get("/hello") { call.respond(ThymeleafContent("index", mapOf("user" to User(1, "しおしお")))) } } } data class User(val id: Long, val name: String)
単純にUserクラスの内容を出力しているだけですね
<!DOCTYPE html > <html xmlns="http://www.w3.org/1999/xhtml" xmlns:th="http://www.thymeleaf.org" xml:lang="ja" lang="ja"> <head> <meta charset="UTF-8"> <title>Title</title> </head> <body> <!--/*@thymesVar id="user" type="siosio.User"*/--> <ul> <li th:text="${user.id}"></li> <li th:text="${user.name}"></li> </ul> </body> </html>
動きましたね(๑•̀ㅂ•́)و✧
elastic4sを使って↓を試してみました。
case classの内容をElasticsearchに登録するcase classにマッピングして取得するbuild.sbtには、elastic4sを追加します。
val elastic4sVersion = "6.5.1" libraryDependencies ++= Seq( "com.sksamuel.elastic4s" %% "elastic4s-core" % elastic4sVersion, "com.sksamuel.elastic4s" %% "elastic4s-http" % elastic4sVersion, )
case class を定義しますIndexableを継承してcase classの内容を登録用のjsonに変換しますcase classを指定しますcase class Data(id: Long, name: String) implicit object SampleIndexable extends Indexable[Data] { override def json(t: Data): String = JacksonSupport.mapper.writeValueAsString(t) } private val client = ElasticClient(ElasticProperties("http://localhost:9200")) client.execute { indexInto("sample" / "_doc").id("1").doc(Data(1, "sample1")) }.await
case classに変換しますcase classに変換して受け取りますimplicit object SampleHitReader extends HitReader[Data] {
override def read(hit: Hit): Try[Data] = {
Try(Data(hit.sourceAsMap("id").toString.toLong, hit.sourceAsMap("name").toString))
}
}
val result = client.execute {
search("sample") termQuery("name", "sample1")
}.await.result.to[Data]
println(result.headOption)
登録したデータが検索できて、Dataクラスにマッピングできてるのが確認できます。
Some(Data(1,sample1))
IntelliJ IDEA 2019.1からはデフォルトではGradleでテスト実行されるようになったようです。
例えばテストを実行すると、こんな感じにGradleで実行されます。
Settings -> Build, Execution, Deployment -> Build Tools -> Gradle -> Runner(↓の画面) から設定を変更します。
設定内容はこんな感じになってます。
Platform Test Runnerを選択しますChose per testを選択しますGradle Test Runnerを選択します。JUnit5を使っている場合、build.gradleにJUnit5用の設定がないとだめなので足してあげましょう。
Gradle&Junit5にあるように、build.gradleにいかが必要となります。
test {
useJUnitPlatform()
}
IntelliJ IDEA 2019.1 Release Candidate is Out! | IntelliJ IDEA Blogにあるように、 2019.1 からの新機能ですね。
デバッグ対象のアプリケーションをDockerで動かすためのDockerfileを作ります。
※docker-compose.ymlでもデバッグいけるみたいです。
とりあえず、デバッグできることだけを確認したいので、シンプルにこんな感じにしています。
FROM java:8 COPY build/libs/sample.jar . CMD $JAVA_HOME/bin/java -jar sample.jar
Remoteを選びます
Command line arguments for remote JVMの内容はコピーしておきましょう
Before launchでLaunch Docker before debugを選びます
Launch Docker before debug の設定を行いますCustom Commandには、コピーしたCommand line arguments for remote JVMの内容を使ってリモートデバッグ可能な状態でアプリケーションを起動するようコマンドをを設定します((Custom Commandの設定、再度設定画面開くと消えちゃってますがおそらく設定自体は生きています))java -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=5005 -jar sample.jarと設定しています
こんな感じにコンテナ上で実行されているアプリケーションに対するデバッグが行なえます。
Custom Command での上書き設定がちょっとめんどくさい感じですね
@Scheduled アノテーションを使ってタスクを定期実行し、キャッシュの値を定期的にクリアしています。
spring.cache.type=simple
@Scheduled で10秒毎にキャッシュをクリアするタスクを実行しています@CacheEvictを設定して、削除対象のキャッシュ名とすべてのエントリを削除するようにしています@SpringBootApplication @EnableCaching @EnableScheduling class CacheDemoApplication fun main(args: Array<String>) { runApplication<CacheDemoApplication>(*args) } @RestController @RequestMapping("/sample") class SampleController(private val sampleService: SampleService) { val logger = LoggerFactory.getLogger(SampleController::class.java) @GetMapping fun toUpper(@RequestParam("value") value: String): String { logger.info("value: $value") return sampleService.toUpper(value) } } @Service class SampleService { val logger = LoggerFactory.getLogger(SampleService::class.java) @Cacheable("toupper") fun toUpper(value: String): String { TimeUnit.SECONDS.sleep(1) val upper = value.toUpperCase() logger.info("$value --> $upper") return upper } } @Component class SampleClearCache { val logger = LoggerFactory.getLogger(SampleClearCache::class.java) @Scheduled(fixedRateString = "PT10S", initialDelayString = "PT10S") @CacheEvict(value = ["toupper"], allEntries = true) fun clearCache(): Unit { logger.info("clear cache") } }
2019-03-23 07:28:07.930 INFO 26010 --- [nio-8080-exec-7] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:08.931 INFO 26010 --- [nio-8080-exec-7] siosio.cachedemo.SampleService : a --> A 2019-03-23 07:28:09.220 INFO 26010 --- [nio-8080-exec-8] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:09.993 INFO 26010 --- [nio-8080-exec-9] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:10.665 INFO 26010 --- [io-8080-exec-10] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:11.680 INFO 26010 --- [nio-8080-exec-2] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:12.399 INFO 26010 --- [nio-8080-exec-1] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:13.220 INFO 26010 --- [nio-8080-exec-3] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:14.013 INFO 26010 --- [nio-8080-exec-4] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:14.820 INFO 26010 --- [nio-8080-exec-5] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:15.703 INFO 26010 --- [ scheduling-1] siosio.cachedemo.SampleClearCache : clear cache 2019-03-23 07:28:15.715 INFO 26010 --- [nio-8080-exec-7] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:16.716 INFO 26010 --- [nio-8080-exec-7] siosio.cachedemo.SampleService : a --> A 2019-03-23 07:28:17.837 INFO 26010 --- [nio-8080-exec-8] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:20.011 INFO 26010 --- [nio-8080-exec-9] siosio.cachedemo.SampleController : value: a 2019-03-23 07:28:25.703 INFO 26010 --- [ scheduling-1] siosio.cachedemo.SampleClearCache : clear cache
