实例介绍
【实例简介】android手机上先通过蓝牙链接上RTK，打开程序，打开蓝牙，接收数据，显示数据。主要应用与解析RTK中的数据。
【实例截图】
【核心代码】
package com.lan;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.RadioButton;
import android.widget.RadioGroup;
import android.widget.TextView;
import android.widget.Toast;
import android.widget.ToggleButton;
import android.widget.RadioGroup.OnCheckedChangeListener;
public class RelayControl extends Activity implements OnCheckedChangeListener{
public static boolean isRecording = false;// 线程控制标记
private ToggleButton tgbt1,tgbt2,tgbt3,tgbt4;
private Button releaseCtrl,btBack,btSend;
private OutputStream outStream = null;
private EditText _txtRead,_txtSend ;
private ConnectedThread manageThread;
private Handler mHandler;
private RadioGroup radioType;
private RadioButton rbPC;
private String encodeType ="GBK";
@Override
public void onCreate(Bundle savedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.relaycontrol);
//接收线程启动
manageThread=new ConnectedThread();
mHandler = new MyHandler();
manageThread.Start();
findMyView();
setMyViewListener();
setTitle("返回前需先关闭socket连接");
//接收区不可见
_txtRead.setCursorVisible(false); //设置输入框中的光标不可见
_txtRead.setFocusable(false); //无焦点
}
private void findMyView() {
tgbt1=(ToggleButton) findViewById(R.id.toggleButton1);
tgbt2=(ToggleButton) findViewById(R.id.toggleButton2);
tgbt3=(ToggleButton) findViewById(R.id.toggleButton3);
tgbt4=(ToggleButton) findViewById(R.id.toggleButton4);
releaseCtrl=(Button)findViewById(R.id.button1);
btBack=(Button) findViewById(R.id.button2);
btSend=(Button) findViewById(R.id.btSend);
radioType = (RadioGroup) findViewById(R.id.radio_type);
rbPC =(RadioButton) findViewById(R.id.rb_pc);
_txtRead = (EditText) findViewById(R.id.etShow);
_txtSend = (EditText) findViewById(R.id.etSend);
}
private void setMyViewListener() {
// 监听RadioButton
radioType.setOnCheckedChangeListener(this);
rbPC.setChecked(true);//设置为默认选中为 PC通信
tgbt1.setOnClickListener(new ClickEvent());
tgbt2.setOnClickListener(new ClickEvent());
tgbt3.setOnClickListener(new ClickEvent());
tgbt4.setOnClickListener(new ClickEvent());
releaseCtrl.setOnClickListener(new ClickEvent());
btBack.setOnClickListener(new ClickEvent());
btSend.setOnClickListener(new ClickEvent());
}
public void onDestroy()
{
try {
lylist.btSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
super.onDestroy();
}
public void onCheckedChanged(RadioGroup group, int checkedId){
switch(checkedId){
case R.id.rb_pc:
encodeType="GBK";
break;
case R.id.rb_phone:
encodeType="UTF-8";
break;
default:
break;
}
}
private class ClickEvent implements View.OnClickListener {
public void onClick(View v) {
if (v == releaseCtrl)// 释放连接
{
try {
lylist.btSocket.close();
manageThread.Stop();
//testBlueTooth.serverThread.cancel();
//Toast.makeText(getApplicationContext(), "socket连接已关闭", Toast.LENGTH_SHORT);
setTitle("socket连接已关闭");
} catch (IOException e) {
//Log .e(TAG,"ON RESUME: Unable to close socket during connection failure", e2);
//Toast.makeText(getApplicationContext(), "关闭连接失败", Toast.LENGTH_SHORT);
setTitle("关闭连接失败");
}
}
else if (v == btBack) {// 返回
RelayControl.this.finish();
}
else if (v == tgbt1)// 继电器按钮1
{
if (tgbt1.isChecked() == false)
sendMessage("11");
else if (tgbt1.isChecked() == true)
sendMessage("10");
} else if (v == tgbt2) {
if (tgbt2.isChecked() == false)
sendMessage("21");
else if (tgbt2.isChecked() == true)
sendMessage("20");
} else if (v == tgbt3) {
if (tgbt3.isChecked() == false)
sendMessage("31");
else if (tgbt3.isChecked() == true)
sendMessage("30");
} else if (v == tgbt4) {
if (tgbt4.isChecked() == false)
sendMessage("41");
else if (tgbt4.isChecked() == true)
sendMessage("40");
}else if (v == btSend){
String infoSend =_txtSend.getText().toString();
sendMessage(infoSend);
setTitle("发送成功");
}
}
}
public static void setEditTextEnable(TextView view,Boolean able){
// view.setTextColor(R.color.read_only_color); //设置只读时的文字颜色
if (view instanceof android.widget.EditText){
view.setCursorVisible(able); //设置输入框中的光标不可见
view.setFocusable(able); //无焦点
view.setFocusableInTouchMode(able); //触摸时也得不到焦点
}
}
public void sendMessage(String message) {
//控制模块
try {
outStream = lylist.btSocket.getOutputStream();
} catch (IOException e) {
// TODO Auto-generated catch block
//Log.e(TAG, "ON RESUME: Output stream creation failed.", e);
Toast.makeText(getApplicationContext(), " Output stream creation failed.", Toast.LENGTH_SHORT);
}
byte[] msgBuffer = null;
try {
msgBuffer = message.getBytes(encodeType);//编码
} catch (UnsupportedEncodingException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
Log.e("write", "Exception during write encoding GBK ", e1);
}
//while(true){
try {
outStream.write(msgBuffer);
//Toast.makeText(getApplicationContext(), "发送数据中..", Toast.LENGTH_SHORT);
setTitle("成功发送指令:" message);
} catch (IOException e) {
// TODO Auto-generated catch block
//Log.e(TAG, "ON RESUME: Exception during write.", e);
Toast.makeText(getApplicationContext(), "发送数据失败", Toast.LENGTH_SHORT);
}
}
class ConnectedThread extends Thread
{
private InputStream inStream = null;// 蓝牙数据输入流
private long wait;
private Thread thread;
public ConnectedThread() {
isRecording = false;
this.wait=50;
thread =new Thread(new ReadRunnable());
}
public void Stop() {
isRecording = false;
//thread.stop();
//State bb = thread.getState();
}
public void Start() {
isRecording = true;
State aa = thread.getState();
if(aa==State.NEW){
thread.start();
}else thread.resume();
}
private class ReadRunnable implements Runnable {
public void run() {
while (isRecording) {
try {
inStream = lylist.btSocket.getInputStream();
} catch (IOException e) {
// TODO Auto-generated catch block
//Log.e(TAG, "ON RESUME: Output stream creation failed.", e);
Toast.makeText(getApplicationContext(), " input stream creation failed.", Toast.LENGTH_SHORT);
}
//char[]dd= new char[40];
int length=20;
byte[] temp = new byte[length];
//String readStr="";
//keep listening to InputStream while connected
if (inStream!= null) {
try{
int len = inStream.read(temp,0,length-1);
Log.e("available", String.valueOf(len));
//setTitle("available" len);
if (len > 0) {
byte[] btBuf = new byte[len];
System.arraycopy(temp, 0, btBuf, 0, btBuf.length);
// for(int iii=0;iii<len;iii ){
// String out = new Character ((char) btBuf[iii]).toString();
// readStr = readStr out;
//
// }
// InputStreamReader inputStreamReader = new InputStreamReader(inStream, "UTF-8");
// int bb = inputStreamReader.read(dd,0,dd.length-1);
// String TempStr=new String(String.valueOf(dd).trim().getBytes());
//读编码
String readStr1 = new String(btBuf,encodeType);
mHandler.obtainMessage(01,len,-1,readStr1).sendToTarget();
}
Thread.sleep(wait);// 延时一定时间缓冲数据
}catch (Exception e) {
// TODO Auto-generated catch block
mHandler.sendEmptyMessage(00);
}
}
}
}
}
}
private class MyHandler extends Handler{
@Override
public void dispatchMessage(Message msg) {
switch(msg.what){
case 00:
isRecording=false;
_txtRead.setText("");
_txtRead.setHint("socket连接已关闭");
//_txtRead.setText("inStream establishment Failed!");
break;
case 01:
String info=(String) msg.obj;
_txtRead.append(info);
break;
default:
break;
}
}
}
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论