Пожалуйста, предоставьте свой фрагмент кода Android (куда вы отправляете сообщение) на сервер.
Когда я запускаю код на своем локальном компьютере (у меня нет контроллера Raspberry, поэтому я закомментировал определенные строки):
import sys
import socket
import select
ctrCmd = ['Up', 'Down', 'Left', 'Right', 'Stop', 'Connect']
HOST = ''
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)
tcpSerSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(1)
print('Waiting for connection')
sendInterval = 1.0 # interval(sec) for sending messages to connected clients
rxset = [tcpSerSock]
txset = []
while True:
print("Waiting for connection")
tcpCliSock, addr = tcpSerSock.accept()
print("...connected from :", addr)
try:
while True:
data = ''
data = tcpCliSock.recv(BUFSIZE).decode()
print("This", data)
if not data:
print("No Data", data)
break
if data == ctrCmd[0]:
print("I am here")
# Servomotor.ServoUp()
print("Increase: ")
#tcpCliSock.send("Servo Increases".encode())
if data == ctrCmd[1]:
# Servomotor.ServoDown()
print("Decrease: ")
#tcpCliSock.send("Servo Decreases".encode())
if data == ctrCmd[2]:
# Servomotor.ledOn()
print("Led On")
#tcpCliSock.send("Led On".encode())
if data == ctrCmd[3]:
# Servomotor.ledOff()
print("Led Off")
# tcpCliSock.send("Led Off".encode())
except KeyboardInterrupt:
# Servomotor.close()
# GPIO.cleanup()
print('Exception')
tcpSerSock.close()
И на стороне клиента запустите следующий код:
import sys
import socket
import time
ctrCmd = [b'Up', b'Down', b'Left', b'Right', b'Stop', b'Connect']
HOST = '127.0.0.1'
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)
tcpCliSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpCliSock.connect(ADDR)
time.sleep(1)
for i in range(len(ctrCmd)):
tcpCliSock.send(ctrCmd[i])
time.sleep(1)
data = tcpCliSock.recv(BUFSIZE)
print(data)
tcpCliSock.close()
Что я, наконец, получаю:
Waiting for connection
Waiting for connection
...connected from : ('127.0.0.1', 54430)
This Up
I am here
Increase:
This Down
Decrease:
This Left
Led On
This Right
Led Off
This Stop
This Connect
Как вы, возможно, заметили, ключ в том, что на стороне клиента вместо отправки строки я отправляю байтовый массив (b'Up 'вместо' Up '). Итак, как вы видите, на стороне сервера нет проблем.
Возможно, на вашей стороне Android вам понадобится что-то вроде:
String msg = "Up"
byte[] byteArr = msg.getBytes();
Обновление
Хорошо, я думаю, что вижу, что там происходит. Используя выходной поток Socket, вы можете отправлять только байтовые данные. И на самом деле он конвертирует ваше сообщение в массив байтов (CMD.getBytes ()). Не удивительно, что ваш сервер получает все шаг за шагом, побайтово.
Что вам нужно сделать, это:
public class MainActivity extends AppCompatActivity {
//UI Element
Button btnUp;
Button btnDown;
Button btnLedOn;
Button btnLedOff;
EditText txtAddress;
/*TextView message;*/
Socket myAppSocket = null;
public static String wifiModuleIp = "";
public static int wifiModulePort = 0;
public static String CMD = "0";
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
btnUp = (Button) findViewById(R.id.btnUp);
btnDown = (Button) findViewById(R.id.btnDown);
btnLedOn = (Button) findViewById(R.id.btnLedOn);
btnLedOff = (Button) findViewById(R.id.btnLedOff);
txtAddress = (EditText) findViewById(R.id.ipAddress);
/*message = (TextView) findViewById(R.id.message);*/
btnUp.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
getIPandPort();
CMD = "Up";
Socket_AsyncTask cmd_increase_servo = new Socket_AsyncTask();
cmd_increase_servo.execute();
}
});
btnDown.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
getIPandPort();
CMD = "Down";
Socket_AsyncTask cmd_increase_servo = new Socket_AsyncTask();
cmd_increase_servo.execute();
}
});
btnLedOn.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
getIPandPort();;
CMD = "ON";
Socket_AsyncTask cmd_led_on = new Socket_AsyncTask();
cmd_led_on.execute();
}
});
btnLedOff.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
getIPandPort();
CMD = "OFF";
Socket_AsyncTask cmd_led_off = new Socket_AsyncTask();
cmd_led_off.execute();
}
});
}
public void getIPandPort()
{
String iPandPort = txtAddress.getText().toString();
Log.d("MYTEST","IP String: "+ iPandPort);
String temp[]= iPandPort.split(":");
wifiModuleIp = temp[0];
wifiModulePort = Integer.valueOf(temp[1]);
Log.d("MY TEST","IP:" +wifiModuleIp);
Log.d("MY TEST","PORT:"+wifiModulePort);
}
public class Socket_AsyncTask extends AsyncTask<Void,Void,Void>
{
Socket socket;
OutputStreamWriter osw;
@Override
protected Void doInBackground(Void... params){
try{
InetAddress inetAddress = InetAddress.getByName(MainActivity.wifiModuleIp);
socket = new java.net.Socket(inetAddress,MainActivity.wifiModulePort);
//read input msg from server
osw = new OutputStreamWriter(socket.getOutputStream(), 'UTF-8');
osw.write(CMD, 0, CMD.length());
out.flush();
socket.close();
}catch (UnknownHostException e){e.printStackTrace();}catch (IOException e){e.printStackTrace();}
return null;
}
}
}