package com.example.bludemo;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.UUID;
import android.app.Activity;
import android.bluetooth.BluetoothAdapter;
import android.bluetooth.BluetoothDevice;
import android.bluetooth.BluetoothServerSocket;
import android.bluetooth.BluetoothSocket;
import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.inputmethod.InputMethodManager;
import android.widget.ArrayAdapter;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ListView;
import android.widget.Toast;
public class BluetoothActivity extends Activity {
/* 一些常量，代表服务器的名称 */
public static final String PROTOCOL_SCHEME_RFCOMM = "btspp";
private ListView mListView;
private Button sendButton;
private Button disconnectButton;
private EditText editMsgView;
private ArrayAdapter<String> mAdapter;
private List<String> msgList = new ArrayList<String>();
Context mContext;
private BluetoothServerSocket mserverSocket = null;
private ServerThread startServerThread = null;
private clientThread clientConnectThread = null;
private BluetoothSocket socket = null;
private BluetoothDevice device = null;
private readThread mreadThread = null;;
private BluetoothAdapter mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.chat);
mContext = this;
init();
}
private void init() {
mAdapter = new ArrayAdapter<String>(this, android.R.layout.simple_list_item_1, msgList);
mListView = (ListView) findViewById(R.id.list);
mListView.setAdapter(mAdapter);
mListView.setFastScrollEnabled(true);
editMsgView = (EditText) findViewById(R.id.MessageText);
editMsgView.clearFocus();
sendButton = (Button) findViewById(R.id.btn_msg_send);
sendButton.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View arg0) {
String msgText = editMsgView.getText().toString();
if (msgText.length() > 0) {
sendMessageHandle(msgText);
editMsgView.setText("");
editMsgView.clearFocus();
// close InputMethodManager
InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
imm.hideSoftInputFromWindow(editMsgView.getWindowToken(), 0);
} else
Toast.makeText(mContext, "发送内容不能为空！", Toast.LENGTH_SHORT).show();
}
});
disconnectButton = (Button) findViewById(R.id.btn_disconnect);
disconnectButton.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT) {
shutdownClient();
} else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) {
shutdownServer();
}
BluetoothMsg.isOpen = false;
BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.NONE;
Toast.makeText(mContext, "已断开连接！", Toast.LENGTH_SHORT).show();
}
});
}
private Handler LinkDetectedHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
if (msg.what == 1) {
msgList.add((String) msg.obj);
} else {
msgList.add((String) msg.obj);
}
mAdapter.notifyDataSetChanged();
mListView.setSelection(msgList.size() - 1);
}
};
@Override
protected void onResume() {
BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.CILENT;
if (BluetoothMsg.isOpen) {
Toast.makeText(mContext, "连接已经打开，可以通信。如果要再建立连接，请先断开！", Toast.LENGTH_SHORT).show();
return;
}else{
}
if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT) {
String address = BluetoothMsg.BlueToothAddress;
if (!address.equals("null")) {
device = mBluetoothAdapter.getRemoteDevice(address);
clientConnectThread = new clientThread();
clientConnectThread.start();
BluetoothMsg.isOpen = true;
} else {
Toast.makeText(mContext, "address is null !", Toast.LENGTH_SHORT).show();
}
} else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) {
startServerThread = new ServerThread();
startServerThread.start();
BluetoothMsg.isOpen = true;
}
super.onResume();
}
// 开启客户端
private class clientThread extends Thread {
@Override
public void run() {
try {
// 创建一个Socket连接：只需要服务器在注册时的UUID号
// socket =
// device.createRfcommSocketToServiceRecord(BluetoothProtocols.OBEX_OBJECT_PUSH_PROTOCOL_UUID);
socket = device
.createRfcommSocketToServiceRecord(UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));
// 连接
Message msg2 = new Message();
msg2.obj = "请稍候，正在连接服务器:" BluetoothMsg.BlueToothAddress;
msg2.what = 0;
LinkDetectedHandler.sendMessage(msg2);
socket.connect();
Message msg = new Message();
msg.obj = "已经连接上服务端！可以发送信息。";
msg.what = 0;
LinkDetectedHandler.sendMessage(msg);
// 启动接受数据
mreadThread = new readThread();
mreadThread.start();
} catch (IOException e) {
Log.e("connect", "", e);
Message msg = new Message();
msg.obj = "连接服务端异常！断开连接重新试一试。";
msg.what = 0;
LinkDetectedHandler.sendMessage(msg);
}
}
};
// 开启服务器
private class ServerThread extends Thread {
@Override
public void run() {
try {
/*
* 创建一个蓝牙服务器 参数分别：服务器名称、UUID
*/
mserverSocket = mBluetoothAdapter.listenUsingRfcommWithServiceRecord(PROTOCOL_SCHEME_RFCOMM,
UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));
Log.d("server", "wait cilent connect...");
Message msg = new Message();
msg.obj = "请稍候，正在等待客户端的连接...";
msg.what = 0;
LinkDetectedHandler.sendMessage(msg);
/* 接受客户端的连接请求 */
socket = mserverSocket.accept();
Log.d("server", "accept success !");
Message msg2 = new Message();
String info = "客户端已经连接上！可以发送信息。";
msg2.obj = info;
msg.what = 0;
LinkDetectedHandler.sendMessage(msg2);
// 启动接受数据
mreadThread = new readThread();
mreadThread.start();
} catch (IOException e) {
e.printStackTrace();
}
}
};
/* 停止服务器 */
private void shutdownServer() {
new Thread() {
@Override
public void run() {
if (startServerThread != null) {
startServerThread.interrupt();
startServerThread = null;
}
if (mreadThread != null) {
mreadThread.interrupt();
mreadThread = null;
}
try {
if (socket != null) {
socket.close();
socket = null;
}
if (mserverSocket != null) {
mserverSocket.close();/* 关闭服务器 */
mserverSocket = null;
}
} catch (IOException e) {
Log.e("server", "mserverSocket.close()", e);
}
};
}.start();
}
/* 停止客户端连接 */
private void shutdownClient() {
new Thread() {
@Override
public void run() {
if (clientConnectThread != null) {
clientConnectThread.interrupt();
clientConnectThread = null;
}
if (mreadThread != null) {
mreadThread.interrupt();
mreadThread = null;
}
if (socket != null) {
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
socket = null;
}
};
}.start();
}
// 发送数据
private void sendMessageHandle(String msg) {
if (socket == null) {
Toast.makeText(mContext, "没有连接", Toast.LENGTH_SHORT).show();
return;
}
try {
OutputStream os = socket.getOutputStream();
msg = msg.replaceAll(" ", "");
byte[] bytes = hexStringToBytes(msg);// 要发送这个bytes
os.write(bytes);
} catch (IOException e) {
e.printStackTrace();
}
msgList.add(msg);
mAdapter.notifyDataSetChanged();
mListView.setSelection(msgList.size() - 1);
}
/**
* Convert hex string to byte[] 把为字符串转化为字节数组
*
* @param hexString
* the hex string
* @return byte[]
*/
public static byte[] hexStringToBytes(String hexString) {
hexString = hexString.replaceAll(" ", "");
if (hexString == null || hexString.equals("")) {
return null;
}
hexString = hexString.toUpperCase(Locale.getDefault());
int length = hexString.length() / 2;
char[] hexChars = hexString.toCharArray();
byte[] d = new byte[length];
for (int i = 0; i < length; i ) {
int pos = i * 2;
d[i] = (byte) (charToByte(hexChars[pos]) << 4 | charToByte(hexChars[pos 1]));
}
return d;
}
private static byte charToByte(char c) {
return (byte) "0123456789ABCDEF".indexOf(c);
}
// 读取数据
private class readThread extends Thread {
@Override
public void run() {
byte[] buffer = new byte[1024];
int bytes;
InputStream mmInStream = null;
try {
mmInStream = socket.getInputStream();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
while (true) {
try {
// Read from the InputStream
if ((bytes = mmInStream.read(buffer)) > 0) {
byte[] buf_data = new byte[bytes];
for (int i = 0; i < bytes; i ) {
buf_data[i] = buffer[i];
}
String s = new String(buf_data);
Message msg = new Message();
msg.obj = s;
msg.what = 1;
LinkDetectedHandler.sendMessage(msg);
}
} catch (IOException e) {
try {
mmInStream.close();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
break;
}
}
}
}
@Override
protected void onDestroy() {
super.onDestroy();
if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT) {
shutdownClient();
} else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) {
shutdownServer();
}
BluetoothMsg.isOpen = false;
BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.NONE;
}
}
评论