server.java

基于手机蓝牙的即时通讯平台

import javax.bluetooth.LocalDevice;
import javax.microedition.io.Connector;
import javax.microedition.io.StreamConnectionNotifier;

public class Server extends Thread {

	private DeviceConnection protocol;

	public Server(DeviceConnection protocol) {
		this.protocol = protocol;
	}

	public void run() {
		try {
			LocalDevice device = LocalDevice.getLocalDevice();
			device.setDiscoverable(Setting.DISCOVERY_MODE);
			String url = "btspp://localhost:" + Setting.UUID+ ";name=MainChat";
			Log.log("根据URL创建服务器: " + url);
			StreamConnectionNotifier notifier = (StreamConnectionNotifier) Connector.open(url);
			/*死循环*/
			while (true) { //设定连接监视器
				Log.log("等待连接...");
				protocol.handleServerConnection(new ConnectionBuffer(notifier.acceptAndOpen()));
			}
		} catch (Exception e) {
			Log.log("ServerThread-Exception", e);
		}
	}

}