本文为大家分享了python搭建服务器实现两个Android客户端间收发消息，供大家参考，具体内容如下
python服务器
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
# coding:utf-8import socketimport threadingimport timedef handle_client(client_socket, client_id): """处理客户端请求""" # 获取客户端请求数据 while True: try: request_data = client_socket.recv(1024) except Exception: time.sleep(0.2) continue if len(request_data) > 0: request_lines = request_data.splitlines() print(request_lines[0].decode("utf-8")) #res = int(request_lines[0]) + 1 client_socket_list[(client_id+1) % 2].send(bytes(str(request_lines[0].decode("utf-8"))+"\n", "utf-8")) client_socket_list.remove(client_id)if __name__ == "__main__": server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) """ socket（）是一个函数，创建一个套接字， AF_INET 表示用IPV4地址族， SOCK_STREAM 是说是要是用流式套接字 """ # server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 设置地址重用 server_socket.bind(("10.2.70.42", 8000)) # 绑定端口 server_socket.listen(2) # 开启监听 client_socket_list = [] client_num = 0 Isready = False while True: client_id = client_num client_socket, client_address = server_socket.accept() print("[%s, %s]用户连接上了" % client_address) handle_client_thread = threading.Thread(target=handle_client, args=(client_socket, client_id)) """ tartget表示这个进程到底要执行什么行为 args是target要接受的参数 """ client_socket_list.append(client_socket) client_num += 1 if len(client_socket_list) == 3: client_socket_list.pop(0) client_socket.setblocking(0) handle_client_thread.start() |
Android客户端-Java代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
package com.example.administrator.wuziqi_intenet;import android.os.Handler;import android.os.Message;import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.view.View;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;import android.widget.Toast;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.Socket;import java.net.URLDecoder;import java.net.UnknownHostException;import static com.example.administrator.wuziqi_intenet.R.id.button1;public class MainActivity extends AppCompatActivity { Button button = null; TextView textView = null; EditText editText = null; Socket socket; BufferedWriter pw=null; BufferedReader is=null; String string="baba"; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); new Thread() { @Override public void run() { try{ socket = new Socket("10.2.70.42", 8000); socket.setSoTimeout(10000); pw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); is = new BufferedReader(new InputStreamReader(socket.getInputStream())); } catch (IOException e) { e.printStackTrace(); } } }.start(); button = (Button) findViewById(button1); textView = (TextView) findViewById(R.id.textview); editText = (EditText) findViewById(R.id.input); handler.sendEmptyMessageDelayed(1, 100); button.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { new Thread(){ @Override public void run() { String msg = editText.getText().toString(); try{ pw.write(msg); pw.flush(); } catch (UnknownHostException e) { Toast.makeText(MainActivity.this,"失败1",Toast.LENGTH_SHORT).show(); e.printStackTrace(); } catch (IOException e) { Toast.makeText(MainActivity.this,"失败2",Toast.LENGTH_SHORT).show(); e.printStackTrace(); } } }.start(); editText.setText(""); } }); } private Handler handler = new Handler() { public void handleMessage(Message message) { try { Moving(); } catch (IOException e) { e.printStackTrace(); } } }; private void Moving() throws IOException { new Thread() { @Override public void run() { try { if (is.ready()) string = is.readLine(); } catch (IOException e) { e.printStackTrace(); } } }.start(); byte[] b=string.getBytes(); String s1=new String(b); System.out.println(s1); textView.setText(string); handler.sendEmptyMessageDelayed(1, 100); }} |
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/sb_ihateyou/article/details/78989875
