Действительно простой TCP-клиент
Я хочу с моим приложением ввести в URL моего сервера, например, http://192.168.1.8/ и порт например 1234, Когда мой сервер получает сообщение TCP Request, он отправляет обратно файл (сервер уже реализован).
Я думаю, что мне не нужно что-то сложное, как AsyncTask, так как я не хочу сохранять связь. Получив ответ от сервера, мое соединение должно быть закрыто.
Любое указание для пути вперед или чаевые высоко ценится.
2 ответа
Вот простой TCP-клиент, который использует сокеты, с которыми я работал, основываясь на коде этого урока (код урока также можно найти в этом репозитории GitHub).
Обратите внимание, что этот код предназначен для отправки строк между клиентом и сервером, обычно в формате JSON.
Вот код клиента TCP:
import android.util.Log;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
public class TcpClient {
public static final String TAG = TcpClient.class.getSimpleName();
public static final String SERVER_IP = "192.168.1.8"; //server IP address
public static final int SERVER_PORT = 1234;
// message to send to the server
private String mServerMessage;
// sends message received notifications
private OnMessageReceived mMessageListener = null;
// while this is true, the server will continue running
private boolean mRun = false;
// used to send messages
private PrintWriter mBufferOut;
// used to read messages from the server
private BufferedReader mBufferIn;
/**
* Constructor of the class. OnMessagedReceived listens for the messages received from server
*/
public TcpClient(OnMessageReceived listener) {
mMessageListener = listener;
}
/**
* Sends the message entered by client to the server
*
* @param message text entered by client
*/
public void sendMessage(final String message) {
Runnable runnable = new Runnable() {
@Override
public void run() {
if (mBufferOut != null) {
Log.d(TAG, "Sending: " + message);
mBufferOut.println(message);
mBufferOut.flush();
}
}
};
Thread thread = new Thread(runnable);
thread.start();
}
/**
* Close the connection and release the members
*/
public void stopClient() {
mRun = false;
if (mBufferOut != null) {
mBufferOut.flush();
mBufferOut.close();
}
mMessageListener = null;
mBufferIn = null;
mBufferOut = null;
mServerMessage = null;
}
public void run() {
mRun = true;
try {
//here you must put your computer's IP address.
InetAddress serverAddr = InetAddress.getByName(SERVER_IP);
Log.d("TCP Client", "C: Connecting...");
//create a socket to make the connection with the server
Socket socket = new Socket(serverAddr, SERVER_PORT);
try {
//sends the message to the server
mBufferOut = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
//receives the message which the server sends back
mBufferIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//in this while the client listens for the messages sent by the server
while (mRun) {
mServerMessage = mBufferIn.readLine();
if (mServerMessage != null && mMessageListener != null) {
//call the method messageReceived from MyActivity class
mMessageListener.messageReceived(mServerMessage);
}
}
Log.d("RESPONSE FROM SERVER", "S: Received Message: '" + mServerMessage + "'");
} catch (Exception e) {
Log.e("TCP", "S: Error", e);
} finally {
//the socket must be closed. It is not possible to reconnect to this socket
// after it is closed, which means a new socket instance has to be created.
socket.close();
}
} catch (Exception e) {
Log.e("TCP", "C: Error", e);
}
}
//Declare the interface. The method messageReceived(String message) will must be implemented in the Activity
//class at on AsyncTask doInBackground
public interface OnMessageReceived {
public void messageReceived(String message);
}
}
Затем объявите TcpClient как переменную-член в вашем Activity:
public class MainActivity extends Activity {
TcpClient mTcpClient;
//............
Затем используйте AsyncTask для подключения к серверу и получения ответов в потоке пользовательского интерфейса (обратите внимание, что сообщения, полученные от сервера, обрабатываются в onProgressUpdate() переопределение метода в AsyncTask):
public class ConnectTask extends AsyncTask<String, String, TcpClient> {
@Override
protected TcpClient doInBackground(String... message) {
//we create a TCPClient object
mTcpClient = new TcpClient(new TcpClient.OnMessageReceived() {
@Override
//here the messageReceived method is implemented
public void messageReceived(String message) {
//this method calls the onProgressUpdate
publishProgress(message);
}
});
mTcpClient.run();
return null;
}
@Override
protected void onProgressUpdate(String... values) {
super.onProgressUpdate(values);
//response received from server
Log.d("test", "response " + values[0]);
//process server response here....
}
Чтобы установить соединение с вашим сервером, выполните AsyncTask:
new ConnectTask().execute("");
Затем, отправив сообщение на сервер:
//sends the message to the server
if (mTcpClient != null) {
mTcpClient.sendMessage("testing");
}
Вы можете закрыть соединение с сервером в любое время:
if (mTcpClient != null) {
mTcpClient.stopClient();
}
Спасибо за код. В моем случае у меня были проблемы с получением данных, так как я не использую линейный протокол. Я написал альтернативную реализацию, которая работает с моей конкретной настройкой сервера:
В файле TcpClient.java команду "run()" следует заменить фрагментом кода ниже
public void run () {
mRun = true; try { InetAddress serverAddr = InetAddress.getByName(SERVER_IP); Log.e("TCP Client", "C: Connecting..."); Socket socket = new Socket(serverAddr, SERVER_PORT); try { mBufferOut = new PrintWriter(socket.getOutputStream()); Log.e("TCP Client", "C: Sent."); mBufferIn = new BufferedReader(new InputStreamReader(socket.getInputStream())); int charsRead = 0; char[] buffer = new char[1024]; //choose your buffer size if you need other than 1024 while (mRun) { charsRead = mBufferIn.read(buffer); mServerMessage = new String(buffer).substring(0, charsRead); if (mServerMessage != null && mMessageListener != null) { mMessageListener.messageReceived(mServerMessage);} mServerMessage = null; } Log.e("RESPONSE FROM SERVER", "S: Received Message: '" + mServerMessage + "'");
// остальная часть кода в порядке, см. оригинал
doInBackgroud в ваших сообщениях MainActivity.java отправляет полученное сообщение в onProgressUpdate, вы можете отобразить его в другом объекте, например TextView.
@Override protected void onProgressUpdate(String... values) { super.onProgressUpdate(values); Log.d("test", "response " + values[0]); response.setText(response.getText() + "/n" +values[0]); }
//"response" - это объект TextView, объявленный в вашей функции
public class MainActivity extends AppCompatActivity {
TextView response; //...so on
и функция
protected void onCreate(Bundle savedInstanceState) {
response = (TextView) findViewById(R.id.textView); //..so on
Прежде всего, дайте интернет-разрешение для вашего приложения в Android-манифесте
<uses-permission android:name="android.permission.INTERNET"/>
вы можете использовать AsyncTask чтобы отправить ваш запрос и получить ваш файл так легко
public void send_request() {
send_request sr = new send_request();
sr.execute();
}
class send_request extends AsyncTask<Void, Void, String> {
@Override
protected String doInBackground(Void... voids) {
try { /*note : ip address must be in Quotation mark*/
/*note : port doesn't need to be inside the Quotation mark*/
Socket s = new Socket(/*ip address :*/"192.168.1.8",/*port :*/ 1234);
PrintWriter printWriter = new PrintWriter(s.getOutputStream());
printWriter.write("your message");
printWriter.flush();
printWriter.close();
s.close();
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
@Override
public void onPostExecute(final String Data) {
/*Data is what you receive from your server*/
Log.e("my_Data","Data is : " + Data);
}
}
Попробуйте этот код в TcpClient:
public void run() {
mRun = true;
try {
InetAddress serverAddr = InetAddress.getByName(SERVER_IP);
Log.e("TCP Client", "C: Connecting...");
Socket socket = new Socket(serverAddr, SERVER_PORT);
try {
mBufferOut = new PrintWriter(socket.getOutputStream());
Log.e("TCP Client", "C: Sent.");
mBufferIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
int charsRead = 0; char[] buffer = new char[2024]; //choose your buffer size if you need other than 1024
while (mRun) {
charsRead = mBufferIn.read(buffer);
mServerMessage = new String(buffer).substring(0, charsRead);
if (mServerMessage != null && mMessageListener != null) {
Log.e("in if---------->>", " Received : '" + mServerMessage + "'");
}
mServerMessage = null;
}
Log.e("-------------- >>", " Received : '" + mServerMessage + "'");
} catch (Exception e) {
Log.e("TCP", "S: Error", e);
} finally {
//the socket must be closed. It is not possible to reconnect to this socket
// after it is closed, which means a new socket instance has to be created.
socket.close();
Log.e("-------------- >>", "Close socket " );
}
} catch (Exception e) {
Log.e("TCP", "C: Error", e);
}
}
Это работает правильно. Эта строка в другом коде выше, чтобы вызвать неправильно.
mMessageListener.messageReceived (mServerMessage);
удалите эту строку, и ваше приложение будет работать хорошо. Вы также можете контролировать свой вход в Android Studio.
Вы можете использовать этот код для своего сервера в Голанге. Это мой сервер:
package main
import (
"bufio"
"flag"
"fmt"
"net"
"strconv"
)
var addr = flag.String("addr", "", "The address to listen to; default is \"\" (all interfaces).")
var port = flag.Int("port", 37533, "The port to listen on; default is 37533.")
func main() {
flag.Parse()
fmt.Println("Starting server...")
src := *addr + ":" + strconv.Itoa(*port)
listener, _ := net.Listen("tcp", src)
fmt.Printf("Listening on %s.\n", src)
defer listener.Close()
for {
conn, err := listener.Accept()
if err != nil {
fmt.Printf("Some connection error: %s\n", err)
}
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
remoteAddr := conn.RemoteAddr().String()
LocalAddr :=conn.LocalAddr().String()
fmt.Println("Client LocalAddr " + LocalAddr)
fmt.Println("Client connected from " + remoteAddr)
scanner := bufio.NewScanner(conn)
for {
ok := scanner.Scan()
if !ok {
break
}
handleMessage(scanner.Text(), conn)
}
fmt.Println("Client at " + remoteAddr + " disconnected.")
}
func handleMessage(message string, conn net.Conn) {
fmt.Println("> " + message)
if len(message) > 0 {
conn.Write([]byte("This is from Golang.\n"))
fmt.Println("----------> we send it....")
}
}
Какая среда окончательного развертывания? Ваш код указывает на локальный IP-адрес. Что-то может измениться, когда вы развернете его в реальной серверной среде? Помните о проблемах NAT, если вы запустите этот код на размещенном сервере. Тогда вы не сможете получать пакеты. Рассмотрите возможность использования более сложного протокола (например, Socket.io может помочь)