package zcd.netanything;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import android.app.Fragment;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.LayoutInflater;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.ViewGroup;
import android.widget.Toast;
public class MyCar
extends Fragment
implements OnClickListener{
private static String wifiurl;
private static String wificom;
private static String wificamera;
private Thread mThreadClient =
null;
private Socket mSocketClient =
null;
//视频线程
private Thread mThreadvideo =
null;
private String recvMessageClient ;
//MySurfaceView r;
private boolean isConnect=
false;
//指令发出 数据缓存
static PrintWriter mPrintWriterClient =
null;
static BufferedReader mBufferedReaderClient =
null;
public View onCreateView(LayoutInflater inflater, ViewGroup container,
Bundle savedInstanceState) {
// TODO Auto-generated method stub
View view = inflater.inflate(R.layout.mycar,container,
false);
view.findViewById(R.id.button1).setOnClickListener(this);
view.findViewById(R.id.button2).setOnClickListener(this);
view.findViewById(R.id.button3).setOnClickListener(this);
view.findViewById(R.id.button4).setOnClickListener(this);
view.findViewById(R.id.button5).setOnClickListener(this);
return view;
}
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
}
//内部类 广播接收
public static class myReceiver
extends BroadcastReceiver {
@Override
public void onReceive(Context context, Intent intent) {
// TODO Auto-generated method stub
wifiurl = intent.getStringExtra("wifiurl"
);
wificom = intent.getStringExtra("wificom"
);
wificamera = intent.getStringExtra("wificamera"
);
Toast.makeText(context, "广播已经接收"
, Toast.LENGTH_SHORT).show();
}
}
//来源 http://www.cnblogs.com/xiaobo-Linux/ 赵存档 QQ463431476
//线程mRunnable启动
private Runnable mRunnable =
new Runnable()
{
public void run()
{
try
{
//连接服务器
mSocketClient =
new Socket(wifiurl,Integer.parseInt(wificom));
//取得输入、输出流
mBufferedReaderClient =
new BufferedReader(
new InputStreamReader(mSocketClient.getInputStream()));
mPrintWriterClient =
new PrintWriter(mSocketClient.getOutputStream(),
true);
recvMessageClient = "wifi成功连接";
//消息换行
Message msg =
new Message();
msg.what = 1
;
mHandler.sendMessage(msg);
}
catch (Exception e)
{
recvMessageClient = "连接错误！";
//消息换行
Message msg =
new Message();
msg.what = 1
;
mHandler.sendMessage(msg);
return;
}
setRecvMessage();
}
};
public void setRecvMessage(){
char[] buffer =
new char[256
];
int count = 0
;
while (
true)
{
try
{
if((count = mBufferedReaderClient.read(buffer))>0
)
{
recvMessageClient = getInfoBuff(buffer, count);
//消息换行
//Thread.sleep(500);
Message msg =
new Message();
msg.what = 1
;
mHandler.sendMessage(msg);
//Toast.makeText(getActivity(),recvMessageClient,Toast.LENGTH_SHORT).show();
}
}
catch (Exception e)
{
recvMessageClient = "接收异常:" + e.getMessage() + "\n";
//消息换行
Message msg =
new Message();
msg.what = 0
;
mHandler.sendMessage(msg);
}
}
}
Handler mHandler =
new Handler()
{
public void handleMessage(Message msg)
{
super.handleMessage(msg);
if(msg.what == 0
)
{
Toast.makeText(getActivity(),recvMessageClient,Toast.LENGTH_SHORT).show();//刷新消息机制
}
else if(msg.what == 1
)
{
try
{
String result =
recvMessageClient;
Toast.makeText(getActivity(),result,Toast.LENGTH_SHORT).show();
}catch(Exception e)
{
//Toast.makeText(getActivity(),"无法获取数据，检查网络是否连接！",Toast.LENGTH_SHORT).show();//刷新消息机制
}
}
}
};
//接收处理
private String getInfoBuff(
char[] buff,
int count)
{
char[] temp =
new char[count];
for(
int i=0; i<count; i++
)
{
temp[i] =
buff[i];
}
return new String(temp);
}
/*public void onDestroy() {
super.onDestroy();
if (isConnect)
{
isConnect = false;
try {
if(mSocketClient!=null)
{
mSocketClient.close();
mSocketClient = null;
//mThreadvideo.destroy();
mPrintWriterClient.close();
mPrintWriterClient = null;
recvMessageClient = "网络端口成功";//消息换行
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
}
} catch (IOException e) {
e.printStackTrace();
}
mThreadClient.interrupt();
}
}
*/
public void onClick(View v) {
// TODO Auto-generated method stub
switch(v.getId()){
case R.id.button1:
mPrintWriterClient.print("f"
);
mPrintWriterClient.flush();//清空
Toast.makeText(getActivity(),"前进"
,Toast.LENGTH_SHORT).show();
break;
case R.id.button2:
mPrintWriterClient.print("b"
);
mPrintWriterClient.flush();
Toast.makeText(getActivity(),"后退"
,Toast.LENGTH_SHORT).show();
break;
case R.id.button3:
mPrintWriterClient.print("l"
);
mPrintWriterClient.flush();
Toast.makeText(getActivity(),"向左"
,Toast.LENGTH_SHORT).show();
break;
case R.id.button4:
mPrintWriterClient.print("r"
);
mPrintWriterClient.flush();
Toast.makeText(getActivity(),"向右"
,Toast.LENGTH_SHORT).show();
break;
case R.id.button5:
if(!
isConnect)
{
//开启mThreadClient线程
mThreadClient =
new Thread(mRunnable);
mThreadClient.start();
Toast.makeText(getActivity(),"尝试连接网络",500
).show();
}
else {
onDestroy();
isConnect=
false;
// Btn_openwifi.setBackgroundResource(R.drawable.disconnect);
}
//开启mThreadvideo线程
//mThreadvideo = new Thread(mRunvideo);
//mThreadvideo.start();//开启视频监听
break;
//case R.id.button6:
//关闭wifi
/* if (isConnect)
{
isConnect = false;
try {
if(mSocketClient!=null)
{
mSocketClient.close();
mSocketClient = null;
//mThreadvideo.destroy();
mPrintWriterClient.close();
mPrintWriterClient = null;
recvMessageClient = "网络端口成功";//消息换行
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
}
} catch (IOException e) {
e.printStackTrace();
}
mThreadClient.interrupt();
}
*/
// break;
}
}
}
转载于:https://www.cnblogs.com/zhaocundang/p/5557456.html
相关资源：JAVA上百实例源码以及开源项目
