ライブ配信受信側のJavaプログラム:JMF

送信側は JMStudio を使って、USBカメラの映像を送信する。
送信の設定は　ライブ配信テスト:JMF　で確認。

import javax.media.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.io.*;

/** Media Frame */
public class ReceiverTest extends JFrame {

    private Player player = null;
    private InputPanel ipanel;
    private Component canvas;
    private Component panel;
    private static final int PORT = 22224;

    public ReceiverTest() {

        super( "RTP Receiver" );
        ipanel = new InputPanel();
        getContentPane().add( ipanel, "North" );
        pack();
    }

  /** start play */
    public void startPlayer() {
        try {
            MediaLocator locator
              = new MediaLocator( "rtp://" + ipanel.host.getText()
                         + ":" + PORT + "/video" );
            player = Manager.createRealizedPlayer( locator );
            canvas = player.getVisualComponent();
            if ( canvas != null) {
                 getContentPane().add( canvas, "Center" );
            }
            panel = player.getControlPanelComponent();
            if ( panel != null) {
                 getContentPane().add( panel, "South" );
            }
            pack();
            player.start();
        } catch (Throwable t) {
            t.printStackTrace();
        }
    }

  /** start here */
    public static void main(String[] args) {
        try {
            ReceiverTest frame = new ReceiverTest(); 
            frame.show();
        } catch (Throwable t) {
            t.printStackTrace();
        }
    }

  /** Input receive host name, port number */
    class InputPanel extends JPanel implements ActionListener {

         public JLabel label = new JLabel( "Transmitter Adress:" );
         public JTextField host = new JTextField( "", 16 );
         public JButton receive = new JButton( "Receive" );

         InputPanel() {

              add( label );
              add( host );
              add( receive );
              receive.addActionListener( this );
         }

      /** Event Processing */
         public void actionPerformed( ActionEvent evt ) {

              if( evt.getSource() instanceof JButton ) {
                  if( (JButton)(evt.getSource()) == receive ) {
                      startPlayer();
                  }
              }
          }
     }
}

ライブ配信テスト:JMF

JMF をインストールしたときに入っている、JMStudio でライブ配信テストをやってみる。

怒涛のめもめもリンク集
JMF: JMStudioでRTP試し　に詳しく解説してある。

JMStudio で送信側と受信側のテストが出来る。

一台のパソコンで送信側と受信側のテストをしてみる。

送信側の設定
JMStudio を起動させて、File から Transmit.. を選択する。

---

Caputure..をクリックする。

OK をクリックする
Next>> をクリックする。

---

Next>> をクリックする。

---

Finish をクリックする。

---

送信を確認する画面が表示される。

---

---

受信側の設定
JMStudio をもう一回起動させる。
File から Open RTP Session..をクリックする。

---

アドレスを入力して Open をクリックする。

---

送られた画像が表示された。

javaでUSBカメラを使う:JMF

JMF をインストールしたときに入っている、JMStudio でUSBカメラが利用できるか確認してみる。

JMStudio を起動させる。

---

ファイルから Cupture を選択する

---

OKをクリックする。

---

USBカメラの映像が表示される

---

USBカメラが利用出来る事が確認できたので、今度はJava プログラムから利用してみる。

import javax.media.*;
import javax.swing.*;

public class jmf {
    public static void main(String args[]) throws Exception {
        JFrame frame = new JFrame("ImageView");
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        Player player = Manager.createRealizedPlayer(new MediaLocator("vfw://0"));
        frame.setBounds(100, 100, 640, 480);
        frame.getContentPane().add(player.getVisualComponent());
        frame.setVisible(true);
        player.start();
    }
}

Eclipseにjar追加 C:\Program Files (x86)\JMF2.1.1e\lib　の中のjar ファイルをEclipseの メニューのプロジェクト->プロパティー->Java のビルド・パス->ライブラリの外部Jaｒの追加ボタンから追加する。

プログラムを実行すると、カメラ映像が表示される。

JMFをWindows 7,64bit,Eclipseでインストール

1.jdk 32bit版のインストール
すでに64bit版がインストールしている場合でも、インストールする。

2.JMFをダウンロードしてくる。
ダウンロードサイト：http://www.oracle.com/technetwork/java/javasebusiness/downloads/java-archive-downloads-java-client-419417.html#7372-jmf-2.1.1e-oth-JPR

ダウンロードしたファイル：jmf-2_1_1e-windows-i586.exe


ダウンロードしたファイルをダブルクリックしてインストール。
解凍からインストールに進まない場合は、jdk 32bitのインストールが完了していない場合があります。

インストールが完了したらデスクトップにJMStudioのアイコンが表示される。

3.Eclipseにjar追加
C:\Program Files (x86)\JMF2.1.1e\lib　の中のjar ファイルをEclipseの
メニューのプロジェクト->プロパティー->Java のビルド・パス->ライブラリの外部Jaｒの追加ボタンから追加する。

テーブルの作成:Java Sqlite

//テーブルを作成
stmt.execute( "create table data( id INTEGER )" );

//テーブルが無い場合に作成
stmt.execute("create table if not exists data ( id INTEGER )");

サーバソケット

import java.io.*;
import java.net.*;

public class echoServer {
    public static void main(String args[]) {
        // ソケットや入出力用のストリームの宣言
        ServerSocket echoServer = null;
        Socket clientSocket = null;
        
        String line;
        BufferedReader is;
        PrintStream os;
        
        // ポート9999番を開く
        try {
         //待ち受けポートを指定して新しいサーバソケットを生成しています。
            echoServer = new ServerSocket(9999);
            System.out.println("EchoServerが起動しました(port=" + echoServer.getLocalPort() + ")");
            
            //acceptメソッドを呼び出し、クライアントからの接続待機状態に入ります。クライアントからの接続要求があると、socketにはクライアントとの通信に利用できるSocketのインスタンスが代入されます。
            clientSocket = echoServer.accept();
            System.out.println("接続されました "+ clientSocket.getRemoteSocketAddress() );
            
            is = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            os = new PrintStream(clientSocket.getOutputStream());

            // クライアントからのメッセージを待ち、受け取ったメッセージをそのまま返す
            while ( (line = is.readLine()) != null ) {
                System.out.println("受信: " + line);
                os.println(line);
                System.out.println("送信: " + line);
              }
        }
        catch (IOException e) {
            System.out.println(e);
        }
        
    }
}

import java.io.*;
import java.net.*;

public class echoClient {
    public static void main(String[] args) {
        //　ソケットや入出力用のストリームの宣言
        Socket echoSocket = null;
        DataOutputStream os = null;
        BufferedReader is = null;

        // ポート9999番を開く
        try {
            echoSocket = new Socket("localhost", 9999);
            os = new DataOutputStream(echoSocket.getOutputStream());
            is = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
        } catch (UnknownHostException e) {
            System.err.println("Don't know about host: localhost");
        } catch (IOException e) {
            System.err.println("Couldn't get I/O for the connection to: localhost");
        }

        // サーバーにメッセージを送る
        if (echoSocket != null && os != null && is != null) {
            try {
                // メッセージを送ります
                os.writeBytes("HELLO\n");

                // サーバーからのメッセージを受け取り画面に表示します
                String responseLine;
                if ((responseLine = is.readLine()) != null) {
                    System.out.println("Server: " + responseLine);
                }

                // 開いたソケットなどをクローズ
                os.close();
                is.close();
                echoSocket.close();
            } catch (UnknownHostException e) {
                System.err.println("Trying to connect to unknown host: " + e);
            } catch (IOException e) {
                System.err.println("IOException: " + e);
            }
        }
    }
}

SQLlite:グループ化

検索対象データベース

集計関数
MAX　最大値
MIN　最小値
AVG　平均値
COUNT　データの個数

合計(Sum)
name別にpriceの合計を計算して表示

ResultSet rs = stmt.executeQuery("SELECT name,Sum(name) FROM data GROUP BY name "); 

while (rs.next()) {
 System.out.println("name = " + rs.getString("name"));
 System.out.println("price = " + rs.getInt(2));
}

結果：
name = いちご
price = 110
name = りんご
price = 201

データの個数(Count)

ResultSet rs = stmt.executeQuery("SELECT name,Count(name) FROM data GROUP BY name ");

while (rs.next()) {
 System.out.println("name = " + rs.getString("name"));
 System.out.println("count = " + rs.getInt(2));
}

結果：
name = いちご
count= 1
name = りんご
count= 2


複数の集計関数を指定

ResultSet rs = stmt.executeQuery("SELECT name,Sum(price),Avg(price) FROM data GROUP BY name ");

while (rs.next()) {
 System.out.println("name = " + rs.getString("name"));
 System.out.println("合計 = " + rs.getInt(2));
 System.out.println("平均 = " + rs.getFloat(3));
}

結果：
name = いちご
合計 = 110
平均 = 110.0
name = りんご
合計 = 201
平均 = 100.5

列名の指定(AS)

ResultSet rs = stmt.executeQuery("SELECT name,Sum(price) AS '合計' FROM data GROUP BY name ");

while (rs.next()) {
 System.out.println("name = " + rs.getString("name"));
 System.out.println("合計 = " + rs.getInt("合計"));
}

特定の集計行のみの表示(HAVING)

ResultSet rs = stmt.executeQuery("SELECT name,Sum(price) AS '合計' FROM data GROUP BY name HAVING Sum(price) > 200 ");

while (rs.next()) {
 System.out.println("name = " + rs.getString("name"));
 System.out.println("合計 = " + rs.getInt("合計"));
}

結果：
name = りんご
合計 = 201