import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
public TCPSocketSender(int port, TCPMessageInterface obj) {
	arr = new String[3];
	arr[0] = "0";
	arr[1] = "0";
	arr[2] = "0";

	if (obj != null)
		JSON = obj;
	// Open a client connection.

	addressIn = "socket://:" + port;

	enable = false;
	init = false;

	// sc = (SocketConnection) Connector.open(addressOut);

	try {
		conn = (ServerSocketConnection) Connector.open(addressIn);

		System.out.println("Listening on: " + conn.getLocalAddress()
				+ " on port: " + conn.getLocalPort());
	} catch (IOException e) {
		e.printStackTrace();
	}
}
 

import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
public void run() {
    try {
        final ServerSocketConnection s = (ServerSocketConnection) Connector.open("serversocket://:" + port);
        while (listening) {
            final SocketConnection connection = (SocketConnection) s.acceptAndOpen(); // blocks until a connection is made
            final Thread t = new Thread(new VisionServerConnectionHandler(connection));
            t.start();
            connections.addElement(connection);
            try {
                Thread.sleep(100);
            } catch (final InterruptedException ex) {
                System.out.println("Thread sleep failed.");
            }
        }
    } catch (final IOException e) {
        System.out.println("Socket failure.");
        e.printStackTrace();
    }
}
 

import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
public ServiceRecord getServiceRecord() {
	if (notifier instanceof ServerSocketConnection) {
		return new OBEXTCPServiceRecordImpl((ServerSocketConnection) notifier);
	}
	if (!(notifier instanceof BluetoothConnectionNotifierServiceRecordAccess)) {
		throw new IllegalArgumentException("connection is not a Bluetooth notifier");
	}
	return ((BluetoothConnectionNotifierServiceRecordAccess) notifier).getServiceRecord();
}
 

import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
OBEXTCPServiceRecordImpl(ServerSocketConnection notifier) {
	try {
		port = String.valueOf(notifier.getLocalPort());
		host = notifier.getLocalAddress();
	} catch (IOException e) {
		host = null;
	}
}
 

import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
public void start() {
	t3 = new Thread(new Runnable() {

		public void run() {

			try {

				// Opens a socket to listen for incoming connections
				try {
					conn = (ServerSocketConnection) Connector
							.open(addressIn);

				} catch (IOException e) {
					e.printStackTrace();
				}

				// wait for a client to connect, this blocks until a connect
				// is made
				clientConnected = false;
				System.out.println("Listening on: "
						+ conn.getLocalAddress() + " on port: "
						+ conn.getLocalPort());
				sc = conn.acceptAndOpen();
				System.out.println("Client Connected");
				clientConnected = true;
				

				// make this true if you want to send data to the beaglebone
				// as well
				recvEnable = true;

				listener();
				sender();

			} catch (IOException e) {

			}
		}
	}

	);

	t3.start();
}
 

import javax.microedition.io.ServerSocketConnection; //导入依赖的package包/类
public ConnectionsListener(ServerSocketConnection socket, ConnectionHandler handler) {
    super("ConnectionsListener");
    this.socket = socket;
    this.handler = handler;
}