えんたつの記録

概要

登録

access token取得

翻訳APIの使用

サンプルサイト

実装サンプル

リンク

Serviceについて

サンプル

  val routingService =
    RoutingService.byPath {
      case "/hello" => new HelloService
      case "/echo" => new EchoService
    }

  val server: Server = ServerBuilder()
    .codec(RichHttp[Request](Http()))
    .bindTo(new InetSocketAddress(8080))
    .name("httpserver")
    .build(routingService)

finagleとは

ドキュメント

Futureについて

val result: Future[Int]
val resultStr: Future[String] = result map { i => i.toString }

finagleをはじめる準備

$ g8 typesafehub/scala-sbt

Scala Project Using sbt 

organization [org.example]: jp.tattyamm.finagle.sample
name [Scala Project]: finagle-sample
scala_version [2.9.2]: 2.9.2
version [0.1-SNAPSHOT]: 0.1-SNAPSHOT

Applied typesafehub/scala-sbt.g8 in finagle-sample

resolvers += "sbt-idea-repo" at "http://mpeltonen.github.com/maven/"

addSbtPlugin("com.github.mpeltonen" % "sbt-idea" % "1.0.0")

//sbt-assembly
resolvers += Resolver.url("artifactory", url("http://scalasbt.artifactoryonline.com/scalasbt/sbt-plugin-releases"))(Resolver.ivyStylePatterns)

addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.8.4")

$sbt update
$sbt gen-idea

・File -> Project Structure -> Project -> Project SDKをJavaのバージョン（1.7）に設定。
・File -> Project Structure -> Modules -> 表示されているやつ両方 -> DependenciesのModule SDKをJavaのバージョン（1.7）に設定。
・File -> Project Structure -> Facets -> Scala -> Compiler instantiationでUse ordinary compilerを選択し、Scalaのバージョン等を設定。

・Build -> Edit Configuration -> 左上のプラスボタンからApplicationを選択 -> Main classを適切に設定、Use classpath of moduleをプロジェクト名のものに設定してOKで確定

sbt.version=0.11.3

finagleのはじめ方

import sbt._
import sbt.Keys._
import scala._

object FinaglesampleBuild extends Build {

  lazy val finaglesample = Project(
    id = "finagle-sample",
    base = file("."),
    settings = Project.defaultSettings ++ Seq(
      name := "finagle-sample",
      organization := "jp.tattyamm.finagle.sample",
      version := "0.1-SNAPSHOT",
      scalaVersion := "2.9.2",
      // add other settings here
      resolvers ++= Seq(
        "Twitter Repository" at "http://maven.twttr.com/"
      ),
      libraryDependencies ++= Seq(
        "com.twitter" % "finagle-core" % "5.3.20",
        "com.twitter" % "finagle-http" % "5.3.20"
      )
    )
  )
}

package jp.tattyamm.finagle.sample

import com.twitter.finagle.{Service, SimpleFilter}
import org.jboss.netty.handler.codec.http._
import org.jboss.netty.handler.codec.http.HttpResponseStatus._
import org.jboss.netty.handler.codec.http.HttpVersion.HTTP_1_1
import org.jboss.netty.buffer.ChannelBuffers.copiedBuffer
import org.jboss.netty.util.CharsetUtil.UTF_8
import com.twitter.util.Future
import java.net.InetSocketAddress
import com.twitter.finagle.builder.{Server, ServerBuilder}
import com.twitter.finagle.http.Http

/**
 * This example demonstrates a sophisticated HTTP server that handles exceptions
 * and performs authorization via a shared secret. The exception handling and
 * authorization code are written as Filters, thus isolating these aspects from
 * the main service (here called "Respond") for better code organization.
 */
object HttpServer {
  /**
   * A simple Filter that catches exceptions and converts them to appropriate
   * HTTP responses.
   */
  class HandleExceptions extends SimpleFilter[HttpRequest, HttpResponse] {
    def apply(request: HttpRequest, service: Service[HttpRequest, HttpResponse]) = {

      // `handle` asynchronously handles exceptions.
      service(request) handle { case error =>
        val statusCode = error match {
          case _: IllegalArgumentException =>
            FORBIDDEN
          case _ =>
            INTERNAL_SERVER_ERROR
        }
        val errorResponse = new DefaultHttpResponse(HTTP_1_1, statusCode)
        errorResponse.setContent(copiedBuffer(error.getStackTraceString, UTF_8))

        errorResponse
      }
    }
  }

  /**
   * The service itself. Simply echos back "hello world"
   */
  class Respond extends Service[HttpRequest, HttpResponse] {
    def apply(request: HttpRequest) = {
      val response = new DefaultHttpResponse(HTTP_1_1, OK)
      response.setContent(copiedBuffer("hello world", UTF_8))
      Future.value(response)
    }
  }

  def main(args: Array[String]) {
    val handleExceptions = new HandleExceptions
    val respond = new Respond

    // compose the Filters and Service together:
    val myService: Service[HttpRequest, HttpResponse] = handleExceptions andThen respond

    val server: Server = ServerBuilder()
      .codec(Http())
      .bindTo(new InetSocketAddress(8080))
      .name("httpserver")
      .build(myService)
  }
}

まとめ

参考、または参考になりそうなサイト

更新履歴

実物

ソースコード

Herokuへのデプロイ手順

$ heroku create --stack cedar play2client

web: target/start -Dhttp.port=${PORT} ${JAVA_OPTS}

$ git push heroku herokuapp:master

$ heroku logs --tail

その他技術情報

感想

Herokuとは

今回の環境や条件

まとめ

Herokuを使う準備

$ ssh-keygen -t rsa
Generating public/private rsa key pair.
Enter file in which to save the key (/Users/username/.ssh/id_rsa): /Users/username/.ssh/heroku_rsa
Enter passphrase (empty for no passphrase): (パスワード)
Enter same passphrase again: (パスワード)

Host heroku
User git
HostName heroku.com
IdentityFile    ~/.ssh/heroku_rsa
Port 22
TCPKeepAlive yes
IdentitiesOnly yes

$ ssh-add ~/.ssh/heroku_rsa
Enter passphrase for /Users/username/.ssh/heroku_rsa: 
Identity added: /Users/username/.ssh/heroku_rsa (/Users/username/.ssh/heroku_rsa)

$ heroku login
Enter your Heroku credentials.
Email: (アドレス)
Password (typing will be hidden): (パスワード)
Found the following SSH public keys:
1) github_rsa.pub
2) heroku_rsa.pub
3) id_rsa.pub
Which would you like to use with your Heroku account? 2 (さっきつくった鍵を指定)
Uploading SSH public key /Users/username/.ssh/heroku_rsa.pub... done
Authentication successful.

$ heroku list
=== My Apps
stark-dawn-hogehoge

herokuの準備

$ heroku create --stack cedar checktrend
Creating checktrend... done, stack is cedar
http://checktrend.herokuapp.com/ | git@heroku.com:checktrend.git
Git remote heroku added

$ heroku addons:add memcache:5mb
Adding memcache:5mb on checktrend... failed
 !    Please verify your account to install this add-on
 !    For more information, see http://devcenter.heroku.com/categories/billing
 !    Verify now at https://heroku.com/verify

$ heroku addons:add memcache:5mb
Adding memcache:5mb on checktrend... done, v2 (free)
Use `heroku addons:docs memcache:5mb` to view documentation.

追加できました。確認しましょう。
$ heroku addons
=== checktrend Configured Add-ons
memcache:5mb

Play2のアプリをHeroku向けに書き換える

web: target/start -Dhttp.port=${PORT} ${JAVA_OPTS}

# memcached
# デフォルトのEhCachePluginを無効にします
ehcacheplugin=disabled
# memcachedの設定
#memcached.host="${?MEMCACHE_SERVERS}:11211"
#memcached.user=${?MEMCACHE_USERNAME}
#memcached.password=${?MEMCACHE_PASSWORD}

$ heroku config --app checktrend
=== checktrend Config Vars
JAVA_OPTS:                    -Xmx384m -Xss512k -XX:+UseCompressedOops
MEMCACHE_PASSWORD:            uwaaaaaaaa
MEMCACHE_SERVERS:             nantoka.host
MEMCACHE_USERNAME:            memcachedusername
PATH:                         .sbt_home/bin:/usr/local/bin:/usr/bin:/bin
REPO:                         /app/.sbt_home/.ivy2/cache
SBT_OPTS:                     -Xmx384m -Xss512k -XX:+UseCompressedOops

# memcached
# デフォルトのEhCachePluginを無効にします
ehcacheplugin=disabled
# memcachedの設定
memcached.host="nantoka.net:11211"
memcached.user="username"
memcached.password="password"

デプロイ

$ git init
$ git add .
$ git commit -m "init"

$ git push heroku master

$ git push heroku herokuapp:master 

$ heroku open

$ heroku logs
2012-10-08T09:44:26+00:00 heroku[router]: Blank App -> GET checktrend.herokuapp.com/ dyno= queue= wait= service= status=200 bytes=
2012-10-08T09:44:26+00:00 heroku[router]: Blank App -> GET checktrend.herokuapp.com/favicon.ico dyno= queue= wait= service= status=200 bytes=
2012-10-08T10:06:23+00:00 heroku[api]: Add redistogo:nano add-on by メアド
2012-10-08T10:06:23+00:00 heroku[api]: Release v2 created by メアド
(以下略)

必要に応じてやること

ログを見る

$ heroku logs --tail

$ heroku addons:add loggly:mole

$ heroku addons:add papertrail:choklad

その他コマンド

$ heroku ps
=== web: ``
web.1: created 2012/10/08 19:06:23 (~ 1h ago)

$ heroku run sbt play
(大量のログは略)
       _            _ 
 _ __ | | __ _ _  _| |
| '_ \| |/ _' | || |_|
|  __/|_|\____|\__ (_)
|_|            |__/ 
             
play! 2.0.2, http://www.playframework.org

> Type "help play" or "license" for more information.
> Type "exit" or use Ctrl+D to leave this console.

[TwitterProxy] $ 

$ heroku update

参考

$ heroku addons:add redistogo:nano
Adding redistogo:nano on checktrend... done, v2 (free)
Use `heroku addons:docs redistogo:nano` to view documentation.

$ heroku addons
=== checktrend Configured Add-ons
redistogo:nano

redis.host=${?REDISTOGO_URL}

Caused by: com.typesafe.config.ConfigException$Parse: application.conf: 49: Expecting end of input or a comma, got ':' (if you intended ':' to be part of the value for 'redis.host', try enclosing the value in double quotes, or you may be able to rename the file .properties rather than .conf)

準備

$ brew install memcached
You can enable memcached to automatically load on login with:
    mkdir -p ~/Library/LaunchAgents
    cp /usr/local/Cellar/memcached/1.4.13/homebrew.mxcl.memcached.plist ~/Library/LaunchAgents/
    launchctl load -w ~/Library/LaunchAgents/homebrew.mxcl.memcached.plist

If this is an upgrade and you already have the homebrew.mxcl.memcached.plist loaded:
    launchctl unload -w ~/Library/LaunchAgents/homebrew.mxcl.memcached.plist
    cp /usr/local/Cellar/memcached/1.4.13/homebrew.mxcl.memcached.plist ~/Library/LaunchAgents/
    launchctl load -w ~/Library/LaunchAgents/homebrew.mxcl.memcached.plist

Or start it manually:
    /usr/local/bin/memcached

Add "-d" to start it as a daemon.

/usr/local/bin/memcached

$ play new Play2MemcachedSample
$ cd Play2MemcachedSample
$ play idea

Play2からmemcachedを使う準備

import sbt._
import Keys._
import PlayProject._

object ApplicationBuild extends Build {

  val appName = "Play2MemcachedSample"
  val appVersion = "1.0-SNAPSHOT"

  val appDependencies = Seq(
    // Add your project dependencies here,
    "com.github.mumoshu" %% "play2-memcached" % "0.2.1-SNAPSHOT"
  )

  val main = PlayProject(appName, appVersion, appDependencies, mainLang = SCALA).settings(
    // Add your own project settings here
    resolvers += "Sonatype OSS Snapshots Repository" at "http://oss.sonatype.org/content/groups/public",
    resolvers += "Spy Repository" at "http://files.couchbase.com/maven2" // required to resolve `spymemcached`, the plugin's dependency.
  )

}

5000:com.github.mumoshu.play2.memcached.MemcachedPlugin

# デフォルトのEhCachePluginを無効にします
ehcacheplugin=disabled
# memcachedのアドレスとポートを指定します
memcached.host="127.0.0.1:11211"

Play2からmemcachedを使う

package controllers

import play.api._
import cache.Cache
import play.api.mvc._
import play.api.Play.current

object Application extends Controller {

  def index = Action {

    // set
    try {
      Cache.set("item.key", "item.value")
    } catch {
      case _ => println("Cacheをsetするとこでエラーのはずだが、memcachedを起動していなくてもここに来ない")
    }

    // setにキャッシュの有効期限を秒で指定できる。
    try {
      Cache.set("item.key2", "item.value2", 30)
    } catch {
      case _ => println("Cacheをsetするとこでエラーのはずだが、memcachedを起動していなくてもここに来ない")
    }

    // get 方法1
    //   方法1と2のどちらのように値を決めても良い。
    val valueFromCache1: Option[String] = Cache.getAs[String]("item.key")
    println(valueFromCache1.getOrElse("item.keyがなかった"))

    // get 方法2
    val valueFromCache2: String = Cache.getOrElse[String]("item.key") {
      "item.keyがなかった"
    }
    println(valueFromCache2)

    // get キーが存在しない場合の挙動
    val valueFromCache3: String = Cache.getOrElse[String]("hogehogeohoge") {
      "item.keyがなかった(正常)"
    }
    println(valueFromCache3)

    Ok(views.html.index("Your new application is ready."))
  }

}

play.api.Play.current.plugin[MemcachedPlugin].get.api.remove("keyToRemove")

サンプルプロジェクト

参考

プラグインのインストール

設定

ジョブの作成

JVM Flags
-XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m -Xmx512M -Xss16M

sbt Flags
-Dsbt.log.noformat=true   (デフォルトのまま)

Actions
compile test publish-local

メモ

これとは別の方法によるもの（github hook）

参考

手順

準備

$ play new Play2TwitterSample
$ cd Play2TwitterSample
$ play idea

Oauthログイン

Twitter APIを操作

WS.url("http://mysite.com").get()

val oauthCalculator = OAuthCalculator(ConsumerKey(consumerKey, consumerSecret), RequestToken(accessToken, accessTokenSecret))
val resultPromise = WS.url(url).sign(oauthCalculator).get()

val oauthCalculator = OAuthCalculator(ConsumerKey(consumerKey, consumerSecret), RequestToken(accessToken, accessTokenSecret))
val resultPromise = WS.url(url).sign(oauthCalculator).get()
val resultBody = resultPromise.await.get.body

Async {
  WS.url(url).sign(oauthCalculator).get().map { response =>
    Ok(views.html.index(response.body))
  }
}

補足、コメント

参考

非同期

Async {
  WS.url(url).get().map { response =>
    Ok(views.html.index(response.body))
  }
}

同期

val resultBody = WS.url(url).get().await.get.body

Oauth付き非同期

val oauthCalculator = OAuthCalculator(ConsumerKey(consumerKey, consumerSecret), RequestToken(accessToken, accessTokenSecret))
Async {
  WS.url(url).sign(oauthCalculator).get().map { response =>
    Ok(views.html.index(response.body))
  }
}

Oauth付き同期

val oauthCalculator = OAuthCalculator(ConsumerKey(consumerKey, consumerSecret), RequestToken(accessToken, accessTokenSecret))
val resultPromise = WS.url(url).sign(oauthCalculator).get()
val resultBody = resultPromise.await.get.body

参考

手順

playアプリの作成

$ play new Play2RedisSample

$ cd Play2RedisSample
$ play idea

プラグインの導入

"com.typesafe" %% "play-plugins-redis" % "2.0.2"

import sbt._
import Keys._
import PlayProject._

object ApplicationBuild extends Build {

    val appName         = "Play2RedisSample"
    val appVersion      = "1.0-SNAPSHOT"

    val appDependencies = Seq(
      // Add your project dependencies here,
      "com.typesafe" %% "play-plugins-redis" % "2.0.2"
    )

    val main = PlayProject(appName, appVersion, appDependencies, mainLang = SCALA).settings(
      // Add your own project settings here      
    )

}

550:com.typesafe.plugin.RedisPlugin

$ play
$(playのプロンプトで) reload
$(playのプロンプトで) update
$(playのプロンプトで) idea

$(playのプロンプトで) idea

redisプラグインの使い方

package controllers

import play.api.mvc.{Controller, Action}
import play.api.Play.current
import play.api.cache.Cache

object Application extends Controller {

  def index = Action {

    // set
    try {
      val valueSet = Cache.set("item.key", "item.value")
    } catch {
      case _ => println("Cache.setでエラー")
    }

    // get 方法1
    //   方法1と2のどちらのように値を決めても良い。
    //   ただしkeyが無い場合playには警告が出る。（[warn] application - could not deserialize key:item.key ex:java.lang.NullPointerException）
    val valueFromCache1: Option[String] = Cache.getAs[String]("item.key")
    println(valueFromCache1.getOrElse("item.keyがなかった"))

    // get 方法2
    val valueFromCache2: String = Cache.getOrElse[String]("item.key") {
      "item.keyがなかった"
    }
    println(valueFromCache2)


    Ok(views.html.index("Your new application is ready."))
  }

}

補足

redis.host　デフォルト:localhost
redis.port　デフォルト:6379
redis.timeout　デフォルト:2000
redis.password　デフォルト:null

コメント

参考