基于TCP和多线程实现无线鼠标键盘-Socket(2)

在(1)中，实现了Windows服务端与Android客户端的连接，本节将实现在Windows服务端与Android客户端之间传递数据。

Android客户端的发送线程SendThread.java代码：

package com.hzhi.mouse_mb;

import java.io.DataOutputStream;
import java.net.Socket;

import android.os.Bundle;
import android.os.Message;
import android.util.Log;

public class SendThread extends Thread {

public static Socket socket_client;
public static String str_mk;

// DOS
DataOutputStream dos = null;

// 消息变量
private Message msg;
private Bundle bdl;

public SendThread(Socket skt){

socket_client = skt;

}

public void set_str(String str){

str_mk = str;

}

public void run(){

try
{
dos = new DataOutputStream(socket_client.getOutputStream());
}
catch (Exception e)
{
send_message(MainActivity.msg_error,e.toString());
}

while(true){

try
{
if(str_mk == null)
{
continue;
}
else
{
dos.writeUTF(str_mk);
Log.i("str_mk=", str_mk);
str_mk = null;
}
}
catch (Exception e)
{
send_message(MainActivity.msg_error,e.toString());
}

}

}

// 发送消息(用于更新UI)
public void send_message(int x, String s){

msg = new Message();
bdl = new Bundle();
bdl.putString("1",s);
msg.what = x;
msg.setData(bdl);
MainActivity.main_handler.sendMessage(msg);

}

}

dos = new DataOutputStream(socket_client.getOutputStream())获得了一个DataOutputStream，socket_client.getOutputStream()获得了将数据写入socket_client的OutputStream，并将该OutputStream作为dos的OutputStream；在while(true)循环中，dos.writeUTF(str_mk)，将字符串str_mk写入socket_client，发送给服务端的Socket。

Windows服务端的接收线程tReceive.java代码：

import java.io.DataInputStream;
import java.net.Socket;

public class tReceive extends Thread{

public static Socket sct;
String str_mk;

public tReceive(Socket s) {
super("");
this.sct = s;
}

public void run() {

DataInputStream dis = null;

try
{
dis = new DataInputStream(sct.getInputStream());
}
catch (Exception e)
{
fMain.l_status.setText("错误:" + e);
}

while(true)
{

try
{
str_mk = dis.readUTF();
System.out.println("str_mk=" + str_mk);
fMain.rbt_act(str_mk);
}
catch (Exception e)
{
fMain.l_status.setText("错误:" + e);
}

}

}

}

dis = new DataInputStream(sct.getInputStream()) 获得了一个DataInputStream；sct.getInputStream()) 获得了sct的InputStream，并将该InputStream作为DataInputStream的InputStream；在while(true)循环中，dis.readUTF()读出sct中的数据，并赋值给字符串变量str_mk。