手机与PC的网络协议

                                                 手机客户端与PC服务端的网络通信

                 前面我们学过电脑与电脑之间的通信，以及多人聊天协议，现在我们就用一台电脑做服务器，一部手机做客户端，来实现手机与电脑之间的通信啦。

                 首先，异曲同工，在手机上建立客户端与在电脑上是差不多的，首先我们现在电脑上面建立服务器

如下：

package 手机与PC端通信;

import java.io.IOException;




import java.net.ServerSocket;
import java.net.Socket;



public class Server {
	
	public void setup(int port){
		
			try {
				//创建服务器
				ServerSocket host=new ServerSocket(port);
				System.out.println("通信端口"+port+"成功开启");
				while(true){
					//等待客户端访问
					Socket socket=host.accept();
					System.out.println("有人访问了");
					//把跟客户端交流的事情交给线程处理
					ServerThread st = new ServerThread(socket);
					//开启线程					
					st.start();

				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		
	}
	public static void main(String[] args){
		//传入端口号
		new Server().setup(8888);
	}

}

 接下来建立线程来处理socket得到的输入流以及输出流：

package 手机与PC端通信;

import java.io.DataInputStream;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class ServerThread extends Thread {
	private Socket socket;
	private DataOutputStream  dos;
	public ServerThread(Socket socket){
		this.socket=socket;
	}
	

	public void run(){
		//得到网络连接socket得到的输出输入流
		try {
			//输入流
			InputStream input=socket.getInputStream();
			
			DataInputStream dis=new DataInputStream(input);
			//得到客户端的输出流
			dos=new DataOutputStream(socket.getOutputStream());
			//读取客户端发到服务端的字节
			while(true){
				   int msgType=dis.readInt();
				
					int len=dis.readInt();
					byte[] bytes=new byte[len];
					dis.readFully(bytes);
					String content=new String(bytes,"GB2312");
					System.out.println("客户端说："+content);
					
					
					    //这里是发到客户端的
						String replyString = "服务器收到了("+content+")";
						bytes = replyString.getBytes("GB2312");
						
						//写进是文字  1
						dos.writeInt(1);
						//输出流写进字节长度
						dos.writeInt(bytes.length);
						//写进字节
						dos.write(bytes);
						//刷新
						dos.flush();
					}
				
			
			
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

  这些内容在上节中都已经讲过，这里不做过多阐述

接下来就是重点内容啦，就是在Android中建立客户端，这里我们要使用带安卓插件的eclipse来编写

首先处理界面，我大概定义了一个textview来显示聊天内容，editText来进行输入框的角色，再者就是一个发送按钮，这样一个简单的聊天界面就已经完成了，如下，简洁的小界面，读者们可以自行美化界面哈：

（最后记得绑定发送按钮到指定函数哦）

接下来就是在MainActivity中开始动工了，动工之前，讲一个非常重要的函数Handler，我们知道，在UI界面主线程中，我们肯定要获取到输入框输入的文字来发送到服务器上，Android里面的线程是不能直接访问Ui组件的，例如：在另一个线程调用textView。setText（“23232”）；在编译的时候是没有问题的，但是在运行时就会报错，所以这时候就要用到handler的函数，我们在这里可以理解为一个中介，子线程将信息绑定在handler上，handler将信息更新到主函数UI上，里面会用到callBack函数，具体代码里讲，万事俱备，只差将网络权限添加到你的手机上了，在AndroidMainfest.xml文件中，在<uses-sdk
        android:minSdkVersion="8"
        android:targetSdkVersion="18" />后面添加网络允许代码，就是下面这一句
    <uses-permission android:name="android.permission.INTERNET"/>

接下来，就是UI界面MainActivity.java代码如下：

import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.app.Activity;
import android.util.Log;
import android.view.Menu;
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 MainActivity extends Activity {
    //聊天区域
	private TextView textMsgLog;
	//客户端处理线程
	private ClientThread clientThread;
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_main);
		Button btnSend=(Button)findViewById(R.id.btnSend);
		//聊天显示界面
		textMsgLog=(TextView)findViewById(R.id.textMsgLog);
		Log.i("test", "oooooooooooooo11111");
		//创建Handler对象,介于主线程和子线程一个代理，子线程ClientThread将要传递的数据通过
		//Handler传递给主进程UI，数据在UI上更新
		Handler.Callback callback=new Handler.Callback(){
			public boolean handleMessage(Message msg){
				
					//
					textMsgLog.append("服务器：" + msg.obj.toString() +
					"\n");
				
				return true;
			}
			
		};
		
		
	    Handler handler=new Handler(callback);
	    clientThread =new ClientThread(handler);
	    clientThread.start();
	    
	    
	}
	//将文本输入框的发送给服务器
	public void send(View v){
		
		//得到输入框
		EditText editInput = (EditText)findViewById(R.id.editInput);
		//得到输入框中文字
		String msg = editInput.getText().toString();
		//调用，写到服务器上，返回成功
		boolean result = clientThread.sendText(msg);
		textMsgLog.append("我："+msg+"\n");
		if(result){
		textMsgLog.append("我："+msg+"\n");
		editInput.setText("");
		} else {
		Toast.makeText(this, "发送失败", Toast.LENGTH_LONG).show();
		}
		
	}
		
	

	@Override
	public boolean onCreateOptionsMenu(Menu menu) {
		// Inflate the menu; this adds items to the action bar if it is present.
		getMenuInflater().inflate(R.menu.main, menu);
		return true;
	}

}

 和客户端线程，也就是刚才说的子线程代码：

ackage com.example.eetalk;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

import android.os.Handler;
import android.os.Message;

public class ClientThread extends Thread {
	private Handler handler;
	private DataOutputStream dos;
	private DataInputStream dis;
	private Socket socket;

	public ClientThread(Handler handler) {
		this.handler = handler;
	}

	public void run() {
		try {
			connect();
			dos.writeInt(1);
			dos.writeInt(5);
		    dos.write("hello".getBytes());
			while (true) {
				//读取服务器发过来的数据
				int msgType = dis.readInt();
				//
				System.out.println("121");
					//
					int len = dis.readInt();
					//
					byte[] bytes = new byte[len];
					dis.readFully(bytes);
					//
					String content = new String(bytes, "GB2312");
					Message msg = new Message();
					msg.what = 1;
					//
					msg.obj = content;
					//
					handler.sendMessage(msg);
				
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			//close();
		}

	}

	private void connect() throws UnknownHostException, IOException {
		//
		socket = new Socket("172.27.35.3", 8888);
		//
		dis = new DataInputStream(socket.getInputStream());
		
		dos = new DataOutputStream(socket.getOutputStream());

	}

	private void close() {
		if (dis != null) {
			try {
				dis.close();
			} catch (IOException e) {
			}
		}
		if (dos != null) {
			try {
				dos.close();
			} catch (IOException e) {
			}
		}
		if (socket != null) {
			try {
				socket.close();
			} catch (IOException e) {
			}
		}
	}
	//发送到服务器的
	public boolean sendText(String content){
		try {
		//
		byte[] bytes = content.getBytes("GB2312");
		//
		dos.writeInt(1);
		//
		dos.writeInt(bytes.length);
		//
		dos.write(bytes);
		dos.flush();
		return true;
		} catch (IOException e) {
		e.printStackTrace();
		}
		return false;
		}
}

记住你的手机和你的电脑一定要在同一个局域网，这里可以看出手机的客户端做法与电脑是差不多的，上面手机客户端连接的ip地址是你的电脑连入的ipv4地址，可以在cmd命令里恰如ipconfig来搜寻。

做到这里，将你的app下载到手机，打开服务器，打开手机的应用程序，就可以聊天了，记住打开网络

美美聊天了：

这是服务器

 

这是手机客户端
 

 

 

 做到这里，就可以和手机互发图片和文字啦，这是小编下期的实现目标