实例介绍
【实例简介】
【实例截图】
电脑端是c 开发的
【核心代码】
package gjz.ControlPC;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.SocketException;
import java.util.Enumeration;
import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.os.StrictMode;
import android.text.method.ScrollingMovementMethod;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
public class ControlPCActivity extends Activity {
/** Called when the activity is first created. */
private Button startButton;
private EditText IPText;
private Button sendButtonClient;
private Button sendButtonServer;
private Button CreateButton;
private EditText editMsgText, editMsgTextCilent;
private TextView recvText;
private Button StartMouseButton;
private Context mContext;
private boolean isConnecting = false;
private Thread mThreadClient = null;
private Thread mThreadServer = null;
private Socket mSocketServer = null;
private Socket mSocketClient = null;
static BufferedReader mBufferedReaderServer = null;
static PrintWriter mPrintWriterServer = null;
static BufferedReader mBufferedReaderClient = null;
static PrintWriter mPrintWriterClient = null;
private String recvMessageClient = "";
private String recvMessageServer = "";
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
mContext = this;
StrictMode.setThreadPolicy(new StrictMode.ThreadPolicy.Builder()
.detectDiskReads()
.detectDiskWrites()
.detectNetwork() // or .detectAll() for all detectable problems
.penaltyLog()
.build());
StrictMode.setVmPolicy(new StrictMode.VmPolicy.Builder()
.detectLeakedSqlLiteObjects()
.penaltyLog()
.penaltyDeath()
.build());
IPText= (EditText)findViewById(R.id.IPText);
//IPText.setText("10.0.2.15:");
IPText.setText("192.168.12.131:59671");
startButton= (Button)findViewById(R.id.StartConnect);
startButton.setOnClickListener(StartClickListener);
editMsgTextCilent= (EditText)findViewById(R.id.clientMessageText);
editMsgTextCilent.setText("up");
editMsgText= (EditText)findViewById(R.id.MessageText);
editMsgText.setText("up");
sendButtonClient= (Button)findViewById(R.id.SendButtonClient);
sendButtonClient.setOnClickListener(SendClickListenerClient);
sendButtonServer= (Button)findViewById(R.id.SendButtonServer);
sendButtonServer.setOnClickListener(SendClickListenerServer);
CreateButton= (Button)findViewById(R.id.CreateConnect);
CreateButton.setOnClickListener(CreateClickListener);
recvText= (TextView)findViewById(R.id.RecvText);
recvText.setMovementMethod(ScrollingMovementMethod.getInstance());
StartMouseButton = (Button)findViewById(R.id.StartMouse);
StartMouseButton.setOnClickListener(StartMouseClickListenerServer);
}
private OnClickListener StartClickListener = new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if (isConnecting)
{
isConnecting = false;
try {
if(mSocketClient!=null)
{
mSocketClient.close();
mSocketClient = null;
mPrintWriterClient.close();
mPrintWriterClient = null;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
mThreadClient.interrupt();
startButton.setText("开始连接");
IPText.setEnabled(true);
recvText.setText("信息:\n");
}
else
{
isConnecting = true;
startButton.setText("停止连接");
IPText.setEnabled(false);
mThreadClient = new Thread(mRunnable);
mThreadClient.start();
}
}
};
private OnClickListener SendClickListenerClient = new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if ( isConnecting && mSocketClient!=null)
{
String msgText =editMsgTextCilent.getText().toString();//取得编辑框中我们输入的内容
if(msgText.length()<=0)
{
Toast.makeText(mContext, "发送内容不能为空！", Toast.LENGTH_SHORT).show();
}
else
{
try
{
mPrintWriterClient.print(msgText);//发送给服务器
mPrintWriterClient.flush();
}
catch (Exception e)
{
// TODO: handle exception
Toast.makeText(mContext, "发送异常：" e.getMessage(), Toast.LENGTH_SHORT).show();
}
}
}
else
{
Toast.makeText(mContext, "没有连接", Toast.LENGTH_SHORT).show();
}
}
};
private OnClickListener SendClickListenerServer = new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if ( serverRuning && mSocketServer!=null )
{
String msgText =editMsgText.getText().toString();//取得编辑框中我们输入的内容
if(msgText.length()<=0)
{
Toast.makeText(mContext, "发送内容不能为空！", Toast.LENGTH_SHORT).show();
}
else
{
try
{
mPrintWriterServer.print(msgText);//发送给服务器
mPrintWriterServer.flush();
}
catch (Exception e)
{
// TODO: handle exception
Toast.makeText(mContext, "发送异常：" e.getMessage(), Toast.LENGTH_SHORT).show();
}
}
}
else
{
Toast.makeText(mContext, "没有连接", Toast.LENGTH_SHORT).show();
}
}
};
//线程:监听服务器发来的消息
private Runnable mRunnable = new Runnable()
{
public void run()
{
String msgText =IPText.getText().toString();
if(msgText.length()<=0)
{
//Toast.makeText(mContext, "IP不能为空！", Toast.LENGTH_SHORT).show();
recvMessageClient = "IP不能为空！\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
return;
}
int start = msgText.indexOf(":");
if( (start == -1) ||(start 1 >= msgText.length()) )
{
recvMessageClient = "IP地址不合法\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
return;
}
String sIP = msgText.substring(0, start);
String sPort = msgText.substring(start 1);
int port = Integer.parseInt(sPort);
Log.d("gjz", "IP:" sIP ":" port);
try
{
//连接服务器
mSocketClient = new Socket(sIP, port); //portnum
//取得输入、输出流
mBufferedReaderClient = new BufferedReader(new InputStreamReader(mSocketClient.getInputStream()));
mPrintWriterClient = new PrintWriter(mSocketClient.getOutputStream(), true);
recvMessageClient = "已经连接server!\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
//break;
}
catch (Exception e)
{
recvMessageClient = "连接IP异常:" e.toString() e.getMessage() "\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
return;
}
char[] buffer = new char[256];
int count = 0;
while (isConnecting)
{
try
{
//if ( (recvMessageClient = mBufferedReaderClient.readLine()) != null )
if((count = mBufferedReaderClient.read(buffer))>0)
{
recvMessageClient = getInfoBuff(buffer, count) "\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
}
}
catch (Exception e)
{
recvMessageClient = "接收异常:" e.getMessage() "\n";//消息换行
Message msg = new Message();
msg.what = 1;
mHandler.sendMessage(msg);
}
}
}
};
Handler mHandler = new Handler()
{
public void handleMessage(Message msg)
{
super.handleMessage(msg);
if(msg.what == 0)
{
recvText.append("Server: " recvMessageServer); // 刷新
}
else if(msg.what == 1)
{
recvText.append("Client: " recvMessageClient); // 刷新
}
}
};
//创建服务端ServerSocket对象
private ServerSocket serverSocket = null;
private boolean serverRuning = false;
private OnClickListener CreateClickListener = new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if (serverRuning)
{
serverRuning = false;
try {
if(serverSocket!=null)
{
serverSocket.close();
serverSocket = null;
}
if(mSocketServer!=null)
{
mSocketServer.close();
mSocketServer = null;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
mThreadServer.interrupt();
CreateButton.setText("创建服务");
recvText.setText("信息:\n");
}
else
{
serverRuning = true;
mThreadServer = new Thread(mcreateRunnable);
mThreadServer.start();
CreateButton.setText("停止服务");
}
}
};
//线程:监听服务器发来的消息
private Runnable mcreateRunnable = new Runnable()
{
public void run()
{
try {
serverSocket = new ServerSocket(0);
SocketAddress address = null;
if(!serverSocket.isBound())
{
serverSocket.bind(address, 0);
}
getLocalIpAddress();
//方法用于等待客服连接
mSocketServer = serverSocket.accept();
//接受客服端数据BufferedReader对象
mBufferedReaderServer = new BufferedReader(new InputStreamReader(mSocketServer.getInputStream()));
//给客服端发送数据
mPrintWriterServer = new PrintWriter(mSocketServer.getOutputStream(),true);
//mPrintWriter.println("服务端已经收到数据！");
Message msg = new Message();
msg.what = 0;
recvMessageServer = "client已经连接上！\n";
mHandler.sendMessage(msg);
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
Message msg = new Message();
msg.what = 0;
recvMessageServer = "创建异常:" e.getMessage() e.toString() "\n";//消息换行
mHandler.sendMessage(msg);
return;
}
char[] buffer = new char[256];
int count = 0;
while(serverRuning)
{
try
{
//if( (recvMessageServer = mBufferedReaderServer.readLine()) != null )//获取客服端数据
if((count = mBufferedReaderServer.read(buffer))>0);
{
recvMessageServer = getInfoBuff(buffer, count) "\n";//消息换行
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
}
}
catch (Exception e)
{
recvMessageServer = "接收异常:" e.getMessage() "\n";//消息换行
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
return;
}
}
}
};
public String getLocalIpAddress()
{
try {
for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements();)
{
NetworkInterface intf = en.nextElement();
for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements();)
{
InetAddress inetAddress = enumIpAddr.nextElement();
//if (!inetAddress.isLoopbackAddress())
{
//return inetAddress.getHostAddress();
//recvMessage = inetAddress.getHostAddress() "isAnyLocalAddress: " inetAddress.isAnyLocalAddress()
// "isLinkLocalAddress: " inetAddress.isLinkLocalAddress()
// "isSiteLocalAddress: " inetAddress.isSiteLocalAddress() "\n";
//mHandler.sendMessage(mHandler.obtainMessage());
//if(inetAddress.isSiteLocalAddress())
{
recvMessageServer = "请连接IP：" inetAddress.getHostAddress() ":"
serverSocket.getLocalPort() "\n";
//Message msg = new Message();
//msg.what = 0;
//mHandler.sendMessage(msg);
}
}
}
}
}
catch (SocketException ex) {
recvMessageServer = "获取IP地址异常:" ex.getMessage() "\n";//消息换行
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
}
Message msg = new Message();
msg.what = 0;
mHandler.sendMessage(msg);
return null;
}
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);
}
private OnClickListener StartMouseClickListenerServer = new OnClickListener() {
@Override
public void onClick(View arg0) {
// TODO Auto-generated method stub
if ( (serverRuning && mSocketServer!=null) || (isConnecting && mSocketClient!=null) )
{
Intent intent = new Intent();
intent.setClass(ControlPCActivity.this, mouseActivity.class);
startActivity(intent);
}
else
{
Toast.makeText(mContext, "没有连接", Toast.LENGTH_SHORT).show();
}
}
};
public void onDestroy() {
super.onDestroy();
if (isConnecting)
{
isConnecting = false;
try {
if(mSocketClient!=null)
{
mSocketClient.close();
mSocketClient = null;
mPrintWriterClient.close();
mPrintWriterClient = null;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
mThreadClient.interrupt();
}
if (serverRuning)
{
serverRuning = false;
try {
if(serverSocket!=null)
{
serverSocket.close();
serverSocket = null;
}
if(mSocketServer!=null)
{
mSocketServer.close();
mSocketServer = null;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
mThreadServer.interrupt();
}
}
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论