トークンを取得するだけのスクリプトを作ります。

最終的にちゃんと取得できているかを確認するためのrtmpdumpコマンドをエコー（表示）しています。

#!/bin/sh

# TBS:TBSラジオ
# QRR:文化放送
# LFR:ニッポン放送
# NSB:ラジオNIKKEI
# INT:INTER FM
# FMT:TOKYO FM
# FMJ:J-WAVE
# JORF:ラジオ日本
# BAYFM78:bayfm78
# NACK5:NACK5
# YFM:ＦＭヨコハマ

if [ $# -eq 1 ]; then
  CHANNEL=$1
else
  echo "usage : $0 CHANNEL"
  exit 1
fi

CHANNEL=$1

RTMPDUMP=/usr/local/bin/rtmpdump
FFMPEG=/usr/bin/ffmpeg
MP3PATH=/home/mlin/html/mp3/

OUTFILEBASEPATH=./
OUTFILENAME=${OUTFILEBASEPATH}/`date +%Y-%m-%d`
FLVFILEEXT=".flv"
AACFILEEXT=".aac"
MP3FILEEXT=".mp3"

MARGINTIMEMIN=1
# RECTIME=`expr ${RECTIMEMIN} \* 60 + ${MARGINTIMEMIN} \* 2 \* 30`

# 30sec wait
# echo "===== `date` Wait 30sec. ====="
# for f1 in 0
# do
  # for f2 in 9 8 7 6 5 4 3 2 1 0
  # do
    # echo -n "$f1$f2\r"
    # sleep 1
  # done
# done

#開始時刻
START=`date +%s` 

cd ${OUTFILEBASEPATH}

playerurl=http://radiko.jp/player/swf/player_3.0.0.01.swf
playerfile=./player.swf
keyfile=./authkey.png

#
# get player
#
if [ ! -f $playerfile ]; then
  wget -q -O $playerfile $playerurl

  if [ $? -ne 0 ]; then
    echo "failed get player"
    exit 1
  fi
fi

#
# get keydata (need swftools)
#
if [ ! -f $keyfile ]; then
  swfextract -b 14 $playerfile -o $keyfile

  if [ ! -f $keyfile ]; then
    echo "failed get keydata"
    exit 1
  fi
fi

if [ -f auth1_fms_${CHANNEL} ]; then
  rm -f auth1_fms_${CHANNEL}
fi

#
# access auth1_fms
#
for var in 3 5 7 9 10 0
do
  wget -q \
       --header="pragma: no-cache" \
       --header="X-Radiko-App: pc_1" \
       --header="X-Radiko-App-Version: 2.0.1" \
       --header="X-Radiko-User: test-stream" \
       --header="X-Radiko-Device: pc" \
       --post-data='\r\n' \
       --no-check-certificate \
       --save-headers \
       --tries=5 \
       --timeout=5 \
       -O auth1_fms_${CHANNEL} \
       https://radiko.jp/v2/api/auth1_fms

  if [ $? -ne 0 ]; then
    if [ $var -ne 0 ]; then
      # echo "failed auth1 process [$var sec sleep...retry]"
      sleep $var
    else
      # echo "[[[[ Failed auth1 process --- `date` --- ]]]]"
      exit;
    fi
  else
    # echo "sucsess auth1 process"
    break;
  fi
done
#
# get partial key
#
authtoken=`cat auth1_fms_${CHANNEL} | perl -ne 'print $1 if(/x-radiko-authtoken: ([\w-]+)/i)'`
offset=`cat auth1_fms_${CHANNEL} | perl -ne 'print $1 if(/x-radiko-keyoffset: (\d+)/i)'`
length=`cat auth1_fms_${CHANNEL} | perl -ne 'print $1 if(/x-radiko-keylength: (\d+)/i)'`

partialkey=`dd if=$keyfile bs=1 skip=${offset} count=${length} 2> /dev/null | base64`

# echo "authtoken: ${authtoken} \noffset: ${offset} length: ${length} \npartialkey: $partialkey"
echo ${authtoken}

rm -f auth1_fms_${CHANNEL}

if [ -f auth2_fms_${CHANNEL} ]; then
  rm -f auth2_fms_${CHANNEL}
fi

#
# access auth2_fms
#
for var in 3 5 7 9 10 0
do
  wget -q \
       --header="pragma: no-cache" \
       --header="X-Radiko-App: pc_1" \
       --header="X-Radiko-App-Version: 2.0.1" \
       --header="X-Radiko-User: test-stream" \
       --header="X-Radiko-Device: pc" \
       --header="X-Radiko-Authtoken: ${authtoken}" \
       --header="X-Radiko-Partialkey: ${partialkey}" \
       --post-data='\r\n' \
       --no-check-certificate \
       --tries=5 \
       --timeout=5 \
       -O auth2_fms_${CHANNEL} \
       https://radiko.jp/v2/api/auth2_fms

  if [ $? -ne 0 -o ! -f auth2_fms_${CHANNEL} ]; then
    if [ $var -ne 0 ]; then
      echo "failed auth2 process [$var sec sleep...retry]"
      sleep $var
    else
      echo "[[[[ Failed auth2 process --- `date` --- ]]]]"
      exit;
    fi
  else
    echo "sucsess auth2 process"
    break;
  fi
done

echo "authentication success"

areaid=`cat auth2_fms_${CHANNEL} | perl -ne 'print $1 if(/^([^,]+),/i)'`
echo "areaid: $areaid"

rm -f auth2_fms_${CHANNEL}

echo rtmpdump -v \
              -r "rtmpe://f-radiko.smartstream.ne.jp" \
              --playpath "simul-stream.stream" \
              --app "${CHANNEL}/_definst_" \
              -W $playerurl \
              -C S:"" -C S:"" -C S:"" -C S:$authtoken \
              --live \
              --flv ./test2.flv \
              --stop 30
exit

少し工夫した部分は
　　for var in 3 5 7 9 10 0
の部分ですね。
トークンを得る際にエラーが出る場合を考慮して５回やり直します。
３．５．７と数値が書いてあるのは、その秒数スリープさせるためです、
連続でエラーになった場合には徐々に待ち時間を長くしています。
最後の０で諦める、と言った形です。

ソケット通信を試します。
結構難しいのですが、以下のサンプルを使ってなんとかします。

要は、クライアントからチャンネル情報を送って、
サーバーからトークンを返すだけ、なのでこれで良いのです。

サーバー

さくらインターネットの方でサーバーを起動させます。

#!/usr/bin/perl

use strict;
use warnings;
use Socket;
use Fcntl qw(:flock);

# 2. 受付用ソケット情報の作成
my $local_port = 9000;

#ロック
open  LOCK , "+>" , "./serverlock.${local_port}";
if ( flock LOCK ,LOCK_EX|LOCK_NB ){
    print "OK LOCK!\n";
}else{
    print "NG LOCK!$!\n";
    exit ;
}

# サーバ

# 1. 受付用ソケットの作成

my $sock_receive;
socket($sock_receive, PF_INET, SOCK_STREAM, getprotobyname( 'tcp' ))
  or die "Cannot create socket: $!";


my $pack_addr = sockaddr_in($local_port, INADDR_ANY);

# 3. 受付用ソケットと受付用ソケット情報を結びつける
bind($sock_receive, $pack_addr)
  or die "Cannot bind: $!";

# 4. 接続を受け付ける準備をする。
listen($sock_receive, SOMAXCONN)
  or die "Cannot listen: $!";

# 5. 接続を受け付けて応答する。
my $sock_client; # クライアントとの通信用のソケット

while (accept( $sock_client, $sock_receive )) {
  my $content;
  
  # クライアントからのデータの読み込み
  while (my $line = <$sock_client>) {
    $content .= $line;
  }

  my $ret="Server."
  
  # クライアントへのデータの書き込み
  print $sock_client "$ret";
  close $sock_client;
}

$contentという変数にクライアントからのデータを取得できます。
クライアントにデータを戻すには、
print $sock_client “$ret”;
で行っています。この例は単に「Server.」と返しています。

クライアント

ラズパイからクライアントを起動します。
サーバーに繋いでサーバーからデータを受け取ります。

#!/usr/bin/perl

use strict;
use Socket;

my $CH="";
if (@ARGV == 1){
    $CH=$ARGV[0];
}else{
    print "usage : ./$0 [CHANNEL]\n";
    exit 1;
}

# クライアント
# 1. ソケットの作成
my $sock;
socket($sock, PF_INET, SOCK_STREAM, getprotobyname('tcp' ))
  or die "Cannot create socket: $!";

# 2. ソケット情報の作成

# 接続先のホスト名
my $remote_host = 'サーバーのドメイン';
my $packed_remote_host = inet_aton($remote_host)
  or die "Cannot pack $remote_host: $!";

# 接続先のポート番号
my $remote_port = 9000;

# ホスト名とポート番号をパック
my $sock_addr = sockaddr_in($remote_port, $packed_remote_host)
  or die "Cannot pack $remote_host:$remote_port: $!";

# 3. ソケットを使って接続
connect($sock, $sock_addr)
  or die "Cannot connect $remote_host:$remote_port: $!";

# 4. データの書き込み
# 書き込みバッファリングをしない。
my $old_handle = select $sock;
$| = 1; 
select $old_handle;

print $sock "Hello";

# 書き込みを終了する
shutdown $sock, 1;

# 5. データの読み込み
my $cnt=0;
while (my $line = <$sock>) {
  print "$cnt $line";
  $cnt++;
}

# 6. ソケットを閉じる
close $sock;

サーバーにデータを送るには
print $sock “Hello”;
でやっています。
そのあとの
print “$cnt $line”;
でサーバーからの返答を受け取るというわけです。

そもそも、radikoの録音はどうやっているのでしょうか。

まずはトークンを取得します。

TBSラジオの例です。

wget -q '--header=pragma: no-cache' '--header=X-Radiko-App: pc_1' \
'--header=X-Radiko-App-Version: 2.0.1' '--header=X-Radiko-User: test-stream' \
'--header=X-Radiko-Device: pc' '--post-data=\r\n' \
--no-check-certificate --save-headers --tries=5 --timeout=5 \
-O auth1_fms https://radiko.jp/v2/api/auth1_fms

これでトークンがとれます。

トークン

cat auth1_fms | perl -ne 'print $1 if(/x-radiko-authtoken: ([\w-]+)/i)'

パーティカルキー

#　offset
cat auth1_fms_${OUTFILEPREFIX}_${CHANNEL} | perl -ne 'print $1 if(/x-radiko-keyoffset: (\d+)
/i)'
# length
cat auth1_fms_${OUTFILEPREFIX}_${CHANNEL} | perl -ne 'print $1 if(/x-radiko-keylength: (\d+)
/i)'

取得したoffsetとlengthを使って取得します。

dd if=$keyfile bs=1 skip=[offset] count=[length] 2> /dev/null | base64

例）トークン　S:wdaDhu6evQheSnXIM8vbGA
パーティカルキー　cHHB6YxRZrVhZMRASY1J4w==

ところが、このトークンはまだ使えません。

更に認証を通します。

取得したトークンとパーティカルキーを使います。

wget -q '--header=pragma: no-cache' '--header=X-Radiko-App: pc_1' \
'--header=X-Radiko-App-Version: 2.0.1' '--header=X-Radiko-User: test-stream' \
'--header=X-Radiko-Device: pc' \
'--header=X-Radiko-Authtoken: wdaDhu6evQheSnXIM8vbGA' \
'--header=X-Radiko-Partialkey: cHHB6YxRZrVhZMRASY1J4w==' \
'--post-data=\r\n' --no-check-certificate --tries=5 \
--timeout=5 -O auth2_fms https://radiko.jp/v2/api/auth2_fms

こうして取得したトークンを使えばよいです。

rtmpdump -v -r rtmpe://f-radiko.smartstream.ne.jp --playpath simul-stream.stream \
--app TBS/_definst_ -W http://radiko.jp/player/swf/player_3.0.0.01.swf \
-C S: -C S: -C S: -C S:wdaDhu6evQheSnXIM8vbGA --live \
--flv ./test.flv --stop 30

最後を少し変えれば、そのまま再生もできます。

rtmpdump -v -r rtmpe://f-radiko.smartstream.ne.jp --playpath simul-stream.stream \
--app TBS/_definst_ -W http://radiko.jp/player/swf/player_3.0.0.01.swf \
-C S: -C S: -C S: -C S:wdaDhu6evQheSnXIM8vbGA --live \
--flv - | mplayer -cache 500 -quiet -

mplayerが必要です。

ラジコの録音をDTIでやっていたのですが、どうにも不安定なので、ラズパイでやろうと思ったのですが、何故かうまくいきませんでした。
正確には数日はうまく行っていたのに突然接続不能となりました。
DTIは問題がないので、録音時代が不能になったわけではないみたい。
調べていくうちに、何故か我が家が”富山”と認識されていることがわかりました。
プロバイダをso-netのADSLからコミュファに変更したことが思いっきり影響してしまったようです。

申請して修正してもらってもいいのですが、また暫く経つと別の地域に変わってしまうので解決になりません。
いまは愛知と静岡を行ったり来たりしています。。。

これでは録音機としてまったく使えないので、対策を練りました。

VPNをつかって東京につなぐという方法もありますが、もっと手軽に何とかなる方法を考えました。
録音を開始するにははじめにトークンを取得して、ダウンロードを行います。
どうやらこのトークンを1度取得してしまえば、切断するまでは接続し続けられるようです。

とすれば、東京にサーバーが一つあって、トークンだけそこで取得できれば・・・。
DTIのserversmanが東京にありますので、取得はできそうです。
ただし、DTIはスペック不足なのか不安定です。
そこで、さくらインターネットです。私にはさくらインターネットのスタンダード契約が2つあります。
実は以前ラジコ録音ができないか試しましたが、残念ながら流石に無理でした。
原因はrtmpdumpのインストールが無理だったのです。
しかし、トークンだけなら可能でした。
ラズパイ→さくらインターネットにつなぐ→トークン取得
こんな感じです。
さくらインターネットはレンタルサーバーですので、httpのプロトコルを使っても簡単に取得できそうです。
が・・・、ちょっとそれだとつまらないので、ソケットを使ってみました。
バッチリ成功し、とても面白かったので、この手法を次から説明していこうと思います。