2

TCP モードでOscP5を使用していますが、TcpClientの接続または切断などの変更をリッスンする方法がわかりません。

oscP5 を次のようにインスタンス化します。

tcp = new OscP5(this, TCP_PORT, OscP5.TCP);

ただし、TcpServer リスナーに関連するものはすべて null 参照エラーを引き起こします。たとえば、

println(tcp.tcpServer().getListeners());

それまでの間、私が考えたハックな回避策は、接続数を常にカウントすることです。

tcp.tcpServer().size()

数値が増加するとクライアントが接続され、数値が減少するとクライアントが切断されたことを示します。問題は、クライアントが切断されたときに、自分のリストを持っていて、自分のクライアントのリストから欠落しているクライアントを確認しない限り、どの IP/クライアント ID が切断されたかを知る方法が思いつかないことです。これは非常にハックで、おそらくエラーが発生しやすいと感じます。

import java.util.Arrays;
import java.util.HashMap;
import java.util.List;

import javax.swing.JOptionPane;

import netP5.NetListener;
import netP5.NetMessage;
import netP5.NetStatus;
import netP5.TcpClient;
import oscP5.OscEventListener;
import oscP5.OscMessage;
import oscP5.OscP5;
import oscP5.OscStatus;
import processing.core.PApplet;


public class TCPServer extends PApplet implements NetListener,OscEventListener {

    public static final int TCP_PORT = 32002;

    private OscP5 tcp;
    private int maxClients = 100;
    private TcpClient[] clients = new TcpClient[maxClients];
    private HashMap<String,Integer> clientsMap = new HashMap<String, Integer>();//lookup table to check against duplicates
    private int prevSize = 0;//previous tcp server client list size

    public void setup() {
        size(1000,100);
        tcp = new OscP5(this, TCP_PORT, OscP5.TCP);
        tcp.addListener(this);
    }

    public void draw() {
        int currSize = tcp.tcpServer().size();//get updated size of clients list
        //if there was a change, a client either connected or disconnected
        if(currSize > prevSize) connect(tcp.tcpServer().getClient(prevSize));//prevSize = size-1 at this point
        if(currSize < prevSize) disconnect(); 
        prevSize = currSize;//update internal client size list

        background(255);
        for (int i = 0; i < maxClients; i++) {
            fill(clients[i] == null ? 255 : 127);
            rect(i*10,0,10,10);
        }
    }

    public void oscEvent(OscMessage m) {
        println(m);
    }

    private void connect(TcpClient client){
        String ip = client.netAddress().address();
        if(clientsMap.get(ip) == null){//if the ip is not a duplicate
            int id = getNextAvailableSlot();
            clients[id] = client;//keep track of this client
            clientsMap.put(ip, id);//and it's ip in the LUT
            println("connected " + ip + " at index " + id);
        }
    }
    private void disconnect(){
        List<TcpClient> c = Arrays.asList(tcp.tcpServer().getClients());//not very efficient, just lazy piggyback ride for contains
        for(int i = 0; i < maxClients; i++){//go through locally stored clients
            if(clients[i] != null){//if we one
                if(!c.contains(clients[i])) {//check if it's not already on the updated tcp server client list
                    String ip = clients[i].netAddress().address();
                    clientsMap.remove(ip);//clear LUT entry
                    tcp.tcpServer().remove(clients[i]);//disconnect
                    clients[i].dispose();//close
                    clients[i] = null;//request cleanup
                    println("disconnected " + ip);
                    return;
                }
            }
        }
    }
    private int getNextAvailableSlot(){
        for (int i = 0; i < maxClients; i++)
            if(clients[i] == null) return i;
        return -1;
    }

    public static void main(String[] args) {
        PApplet.main(TCPServer.class.getSimpleName());
    }

    @Override
    public void netEvent(NetMessage e) {
        System.out.println("netEvent:");
        System.out.println(e);
    }

    @Override
    public void netStatus(NetStatus s) {
        System.out.println("netStatus:");
        System.out.println(s);
    }

    @Override
    public void oscStatus(OscStatus s) {
        System.out.println("oscStatus:");
        System.out.println(s);
    }

}

このシナリオで tcp クライアントの接続/切断イベントを監視するクリーンな方法は何ですか?

4

1 に答える 1

2

現在、oscP5 に実装されているそのような概念はありません。ここに同様の議論があります。

デバッグ情報で見つかったメモリアドレスに基づいて、自分で何かを構築する必要があるようです### new Client @ netP5.TcpClient@164b9b6. System.out ストリームで文字列をスキャンしnew Client、メソッドを呼び出しますclientConnected。これは完全にハックですが、現在、別の方法はありません。

import java.io.PrintStream;

import oscP5.*;
import netP5.*;

OscP5 oscP5tcpServer;
OscP5 oscP5tcpClient;
NetAddress myServerAddress;

void setup() {
  // overwrite standard System.out
  System.setOut(new PrintStream(System.out) {
    public void println(String s) {
      if(s.indexOf("new Client") != -1){
        clientConnected(getMemoryAddress(s));
      }
      super.println(s);
    }
    // override some other methods?
  });

  oscP5tcpServer = new OscP5(this, 11000, OscP5.TCP);
  oscP5tcpClient = new OscP5(this, "127.0.0.1", 11000, OscP5.TCP);
}

void clientConnected(int memoryAddress){
  println("Client connected, with memory address " + memoryAddress);
}

int getMemoryAddress(String s){
  return Integer.parseInt(s.substring(s.lastIndexOf('@')+1), 16);
}

void draw() {  
}

void mousePressed() {
  oscP5tcpClient.send("/test", new Object[] {new Integer(1)});
}

void keyPressed() {
  println(oscP5tcpServer.tcpServer().getClients().length);
}

void oscEvent(OscMessage theMessage) {
  System.out.println("### got a message " + theMessage);
  if(theMessage.checkAddrPattern("/test")) {
    OscMessage m = new OscMessage("/response");
    m.add("server response: got it");
    oscP5tcpServer.send(m,theMessage.tcpConnection());
  }
}
于 2013-07-07T08:47:31.100 に答える