Android客户端和Python服务器通信(三)

先上效果图(服务器显示客户端发送的数据):

image.png

本一篇主要解决两个问题：第一个是增加客户端向服务器发送数据功能，实现真正的通信。第二个是修复了服务器UI界面点击退出后依然没有退出的BUG。
Android客户端和Python服务器通信(二)：https://www.jianshu.com/p/3a96a94768eb

Python服务器端:

from socket import *
import easygui
import _thread

def print_time( threadName, delay):
   while True:
      data = tcpClientSocket.recv(BUFFER_SIZE).decode()
      if not data:
          break
      print ("%s: %s" % ( threadName, data ))

test="test01"
# 1 定义域名和端口号
HOST,PORT ='',555
# 2 定义缓冲区(缓存)
BUFFER_SIZE = 1024
ADDR=(HOST,PORT)
# 3 创建服务器套接字 AF_INET:IPv4  SOCK_STREAM:协议
tcpServerSocket = socket(AF_INET,SOCK_STREAM)
# 4 绑定域名和端口号
tcpServerSocket.bind(ADDR)
# 5 监听连接  最大连接数
tcpServerSocket.listen(5)
# 6 定义一个循环 目的:等待客户端的连接
while True:
    # 6.1 打开一个客户端对象 同意连接
    tcpClientSocket,addr = tcpServerSocket.accept()
    print(addr)
    # 连接成功后就弹出界面
    _thread.start_new_thread(print_time, ("Thread-1", 2, ))
    while True:
        Yes_or_No = easygui.buttonbox("socket01是否发送数据?", choices = ['Yes','No','退出'])
        if Yes_or_No=='退出':break
        if Yes_or_No=='Yes':
            tcpClientSocket.send(test.encode())
    tcpClientSocket.close()
    break
tcpServerSocket.close()

Android客户端:

package com.example.mrzheng.socket03;

import android.annotation.SuppressLint;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.widget.Toast;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class MainActivity extends AppCompatActivity {

    private final int HANDLER_MSG_TELL_RECV = 0x124;
    @SuppressLint("HandlerLeak")
    Handler handler01 = new Handler(){
        public void handleMessage(Message msg){
            //接受到服务器信息时执行
            Toast.makeText(MainActivity.this,(msg.obj).toString(),Toast.LENGTH_LONG).show();
        }
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        startNetThread();
    }
    private void startNetThread() {
        new Thread() {
            @Override
            public void run() {
                try {
                    Socket socket = new Socket("192.168.2.200", 555);
                    InputStream inputStream = socket.getInputStream();
                    OutputStream outputStream = socket.getOutputStream();
                    byte[] bytes = new byte[1024];
                    int n =inputStream.read(bytes);
                    while(true) {
                        outputStream.write("ok".getBytes());
                        outputStream.flush();
                        Message msg = handler01.obtainMessage(HANDLER_MSG_TELL_RECV, new String(bytes, 0, n));
                        msg.sendToTarget();
                        n =inputStream.read(bytes);
                    }
                } catch (Exception e) {
                }
            }
        }.start();
    }
}