標準出力のデータを読み込んで放送させることに成功。

やったね。

client.sh

@@ -0,0 +1 @@
+java -Xmx512m -cp conf:lib/*:stdinFlazr.jar com.ttProject.flazr.RtmpClient $*

readme.txt

@@ -6,3 +6,10 @@ stdinFlazr
 ・とりあえず実行母体をつくりました。
 10:27
 ・変更の必要なファイルを抽出して、動作を上書きできるように改良した。
+15:45
+・とりあえずcatでflvを開いてpipeでつないだ動作でうまく動作させることができた。
+$ cat music.flv | ./client.sh -host 49.212.39.17 -app live -live test -
+
+あと、心配なことは、リアルタイム動作させてて、flvデータが枯渇したらどうなるか・・・ですね。
+手持ちにいいソースがないので、とりあえず放置しておきますが・・・
+このあたりきちっとしようとしたら、やっぱりrtmpPublisherの動作に口出しして、現在時刻もうまくトレースする必要があると思う。

src/com/ttProject/flazr/FlvPacketReader.java

@@ -18,13 +18,6 @@ public class FlvPacketReader {
 	private ByteBuffer buffer = null;
 	public List<FlvAtom> getPackets(ByteBuffer data) {
 		if(buffer != null) {
-			int position = buffer.position();
-			byte[] dat = new byte[11];
-			buffer.get(dat);
-			System.out.println(Utils.toHex(dat, true));
-			buffer.position(position);
-			System.out.println(buffer.remaining());
-			System.out.println(data.remaining());
 			int length = buffer.remaining() + data.remaining();
 			ByteBuffer newBuffer = ByteBuffer.allocate(length);
 			newBuffer.put(buffer);
@@ -54,7 +47,6 @@ public List<FlvAtom> getPackets(ByteBuffer data) {
 	 */
 	private FlvAtom analizeData(ByteBuffer buffer) {
 		if(!firstChecked) {
-			System.out.println("check again");
 			if(buffer.remaining() < 13) {
 				// データがたりないので、次のデータ待ち
 				return null;
@@ -95,11 +87,6 @@ private FlvAtom analizeData(ByteBuffer buffer) {
 		int size = getSizeFromHeader(packetHeader);
 		System.out.println(11+ size + 4);
 		if(buffer.remaining() < size + 4) {
-			// 読み込むのにはデータがたりなかった。
-			buffer.position(position);
-			byte[] dat = new byte[11];
-			buffer.get(dat);
-			System.out.println(Utils.toHex(dat, true));
 			buffer.position(position);
 			return null;
 		}

src/com/ttProject/flazr/io/flv/FlvLiveReader.java

@@ -1,8 +1,8 @@
 package com.ttProject.flazr.io.flv;
 
-import java.io.FileInputStream;
 import java.nio.ByteBuffer;
-import java.nio.channels.FileChannel;
+import java.nio.channels.Channels;
+import java.nio.channels.ReadableByteChannel;
 import java.util.List;
 import java.util.concurrent.LinkedBlockingQueue;
 
@@ -34,10 +34,10 @@ public FlvLiveReader(final String path) {
 			public void run() {
 				try {
 					FlvPacketReader reader = new FlvPacketReader();
-//					ReadableByteChannel stdinChannel = Channels.newChannel(System.in);
+					ReadableByteChannel stdinChannel = Channels.newChannel(System.in);
 					// dummy
-					String targetFile = System.getProperty("user.home") + "/Sites/mario/mario.flv";
-					FileChannel stdinChannel = new FileInputStream(targetFile).getChannel();
+//					String targetFile = System.getProperty("user.home") + "/Sites/mario/mario.flv";
+//					FileChannel stdinChannel = new FileInputStream(targetFile).getChannel();
 					// 実処理
 					// データを確認する。
 					while(true) {