在这种情况下，android 应用程序充当服务器。我有一个主要活动，它创建一个线程来处理 serverSocket 和一个不同的线程来处理套接字连接。我正在使用 C# 和 android 通用的 uuid。
我正在为 C# 使用 32 英尺蓝牙库。
我面临的错误是
1) 我的 logcat 显示了这个调试日志
执行 socket.connect()1
java.io.IOException 时出错：文件描述符处于错误状态
消息：文件描述符处于错误状态
本地化消息：文件描述符处于错误状态
接收：测试
线程的连接计数为：1
2）当我尝试第二次通过 C# 应用程序发送内容时，会引发此异常：
A first chance exception of type 'System.InvalidOperationException' occurred in System.dll
System.InvalidOperationException: BeginConnect cannot be called while another asynchronous operation is in progress on the same Socket.
at System.Net.Sockets.Socket.DoBeginConnect(EndPoint endPointSnapshot, SocketAddress socketAddress, LazyAsyncResult asyncResult)
at System.Net.Sockets.Socket.BeginConnect(EndPoint remoteEP, AsyncCallback callback, Object state)
at InTheHand.Net.Bluetooth.Msft.SocketBluetoothClient.BeginConnect(BluetoothEndPoint remoteEP, AsyncCallback requestCallback, Object state)
at InTheHand.Net.Sockets.BluetoothClient.BeginConnect(BluetoothEndPoint remoteEP, AsyncCallback requestCallback, Object state)
at InTheHand.Net.Sockets.BluetoothClient.BeginConnect(BluetoothAddress address, Guid service, AsyncCallback requestCallback, Object state)
at BTSyncClient.Form1.connect() in c:\users\----\documents\visual studio 2010\Projects\TestClient\TestClient\Form1.cs:line 154
我只知道 android 应用程序编程，我通过学习一点点设计了 C# 应用程序。仅供参考，我的 android 手机是运行 ICS 的galaxy s。请指出我的错误..
源代码：
C# 代码
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading;
using System.Net.Sockets;
using InTheHand.Net.Bluetooth;
using InTheHand.Windows.Forms;
using InTheHand.Net.Sockets;
using InTheHand.Net;
namespace BTSyncClient
{
public partial class Form1 : Form
{
BluetoothClient myself;
BluetoothDeviceInfo bTServerDevice;
private Guid uuid = Guid.Parse("00001101-0000-1000-8000-00805F9B34FB");
bool isConnected;
public Form1()
{
InitializeComponent();
if (BluetoothRadio.IsSupported)
{
myself = new BluetoothClient();
}
}
private void Form1_Load(object sender, EventArgs e)
{
}
private void button1_Click(object sender, EventArgs e)
{
connect();
}
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
try
{
myself.GetStream().Close();
myself.Dispose();
}
catch (Exception ex) { Console.Out.WriteLine(ex); }
}
private void button2_Click(object sender, EventArgs e)
{
SelectBluetoothDeviceDialog dialog = new SelectBluetoothDeviceDialog();
DialogResult result = dialog.ShowDialog(this);
if(result.Equals(DialogResult.OK)){
bTServerDevice = dialog.SelectedDevice;
}
}
private void callback(IAsyncResult ar)
{
String msg = (String)ar.AsyncState;
if (ar.IsCompleted)
{
isConnected = myself.Connected;
if (myself.Connected)
{
UTF8Encoding encoder = new UTF8Encoding();
NetworkStream stream = myself.GetStream();
if (!stream.CanWrite)
{
MessageBox.Show("Stream is not Writable");
}
System.IO.StreamWriter mywriter = new System.IO.StreamWriter(stream, Encoding.UTF8);
mywriter.WriteLine(msg);
mywriter.Flush();
}
else
MessageBox.Show("Damn thing isnt connected");
}
}
private void connect()
{
try
{
if (bTServerDevice != null)
{
myself.BeginConnect(bTServerDevice.DeviceAddress, uuid, new AsyncCallback(callback)
, message.Text);
}
}
catch (Exception e) { Console.Out.WriteLine(e); }
}
}
}
服务器线程
import java.io.IOException;
import java.util.UUID;
import android.bluetooth.BluetoothAdapter;
import android.bluetooth.BluetoothServerSocket;
import android.bluetooth.BluetoothSocket;
import android.util.Log;
public class ServerSocketThread extends Thread {
private static final String TAG = "TestApp";
private BluetoothAdapter btAdapter;
private BluetoothServerSocket serverSocket;
private boolean stopMe;
private static final UUID uuid = UUID.fromString("00001101-0000-1000-8000-00805F9B34FB");
//private static final UUID uuid = UUID.fromString("6e58c9d5-b0b6-4009-ad9b-fd9481aef9b3");
private static final String SERVICE_NAME = "TestService";
public ServerSocketThread() {
stopMe = false;
btAdapter = BluetoothAdapter.getDefaultAdapter();
try {
serverSocket = btAdapter.listenUsingRfcommWithServiceRecord(SERVICE_NAME, uuid);
} catch (IOException e) {
Log.d(TAG,e.toString());
}
}
public void signalStop(){
stopMe = true;
}
public void run(){
Log.d(TAG,"In ServerThread");
BluetoothSocket socket = null;
while(!stopMe){
try {
socket = serverSocket.accept();
} catch (IOException e) {
break;
}
if(socket != null){
AcceptThread newClientConnection = new AcceptThread(socket);
newClientConnection.start();
}
}
Log.d(TAG,"Server Thread now dead");
}
// Will cancel the listening socket and cause the thread to finish
public void cancel(){
try {
serverSocket.close();
} catch (IOException e) {
}
}
}
接受线程
import java.io.IOException;
import java.io.InputStream;
import java.util.Scanner;
import android.bluetooth.BluetoothSocket;
import android.util.Log;
public class AcceptThread extends Thread {
private BluetoothSocket socket;
private String TAG = "TestApp";
static int count = 0;
public AcceptThread(BluetoothSocket Socket) {
socket = Socket;
}
volatile boolean isError;
String output;
String error;
public void run() {
Log.d(TAG, "AcceptThread Started");
isError = false;
try {
socket.connect();
} catch (IOException e) {
Log.d(TAG,"Error while doing socket.connect()"+ ++count);
Log.d(TAG, e.toString());
Log.d(TAG,"Message: "+e.getLocalizedMessage());
Log.d(TAG,"Localized Message: "+e.getMessage());
isError = true;
}
InputStream in = null;
try {
in = socket.getInputStream();
} catch (IOException e) {
Log.d(TAG,"Error while doing socket.getInputStream()");
Log.d(TAG, e.toString());
Log.d(TAG,"Message: "+e.getLocalizedMessage());
Log.d(TAG,"Localized Message: "+e.getMessage());
isError = true;
}
Scanner istream = new Scanner(in);
if (istream.hasNextLine()) {
Log.d(TAG, "Received : "+istream.nextLine());
Log.d(TAG,"Count of Thread is : " + count);
}
istream.close();
try {
in.close();
} catch (IOException e) {
Log.d(TAG,"Error while doing in.close()");
Log.d(TAG, e.toString());
Log.d(TAG,"Message: "+e.getLocalizedMessage());
Log.d(TAG,"Localized Message: "+e.getMessage());
isError = true;
}
try {
socket.close();
} catch (IOException e) {
Log.d(TAG,"Error while doing socket.close()");
Log.d(TAG, e.toString());
Log.d(TAG,"Message: "+e.getLocalizedMessage());
Log.d(TAG,"Localized Message: "+e.getMessage());
isError = true;
}
}
}