首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >如何解决Android可以向服务器发送消息但无法从服务器接收消息?

如何解决Android可以向服务器发送消息但无法从服务器接收消息?
EN

Stack Overflow用户
提问于 2018-08-08 00:33:36
回答 1查看 0关注 0票数 0

以下是代码:

代码语言:txt
复制
package com.example.clienttest;

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

import android.os.Bundle;
import android.app.Activity;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;

public class MainActivity extends Activity {

    Thread m_objThreadClient;
    Socket clientSocket;
    TextView serverMessage;
    EditText clientMessage;
    String sIn = "Nothing", sOut;
    DataOutputStream oos;
    DataInputStream ois;

    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        serverMessage = (TextView) findViewById(R.id.textView1);
        clientMessage = (EditText) findViewById(R.id.editText1);


        m_objThreadClient = new Thread( new Runnable(){
            public void run()
            {
                try {
                    clientSocket = new Socket("192.168.1.55", 4000);
                    oos = new DataOutputStream (clientSocket.getOutputStream());
                    ois = new DataInputStream (clientSocket.getInputStream());


                } catch (Exception e) {
                    serverMessage.setText(e.getMessage());
                }

            }
        });
        m_objThreadClient.start();


    }

    public void Start(View view) {
        sOut = clientMessage.getText().toString();
          try {
              oos.writeUTF(sOut);

              ServerConn sc = new ServerConn(clientSocket);
              Thread t = new Thread(sc);
              t.start();

              serverMessage.setText("Reply: " + sc.msg + "\n");

              } catch (Exception e) {
              serverMessage.setText(e.getMessage());
              }

    }

    public void onStop(){
        try {
            oos.close();
            ois.close();
            clientSocket.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

class ServerConn implements Runnable {
    private DataInputStream ois = null;
    public String msg;

    public ServerConn(Socket server) throws IOException {
         ois = new DataInputStream (server.getInputStream());
    }

    public void run() {
        try {

            while ((msg = ois.readUTF()) != null) {
            }
        } catch (IOException e) {
            msg = e.toString();
        }
    }
}

服务器代码

代码语言:txt
复制
import java.net.ServerSocket;
import java.net.Socket;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.PrintWriter;

import java.util.Hashtable;

public class Server2 {

    @SuppressWarnings("resource")
    public static void main (String[] args) throws IOException {

        ServerSocket server = null;  
        try {
            server = new ServerSocket(4000); 
        } catch (IOException e) {
            System.err.println("Could not start up on: " + "4000" + "Maby server is already open? Or a portforwording messup?");
            System.err.println(e);
            System.exit(1);
        }

        Socket client = null;
        while(true) {
            try {
                client = server.accept();
                System.out.print("Connected ");
            } catch (IOException e) {
                System.err.println("Accept failed.");
                System.err.println(e);
            }

            Thread t = new Thread(new ClientConn(client));
            t.start();
        }
    }
}


class ClientConn implements Runnable {
    private Socket client;
    String Recv, Send;
    DataInputStream inFromClient;
    DataOutputStream outToClient;

    ClientConn(Socket client) {
        this.client = client;
        try {

            inFromClient = new DataInputStream(client.getInputStream());
            outToClient = new DataOutputStream(client.getOutputStream());
            } catch (IOException e) {
            e.printStackTrace();
            }
    }

    public void run() {
        try {
            while ((Recv = inFromClient.readUTF()) != null) {

                System.out.print("Msg: " + Recv + " \n");
                if( Recv.equals("Hi")){
                    Send = "Wa alaikum";
                }
                else{
                    Send = "Wat?";
                }

                outToClient.writeUTF(Send);
                outToClient.flush();
                System.out.print("Replying:" + Send + "\n");
            }
        } catch (IOException e) {
            System.out.print("No input ");
            System.err.println(e);
        }
    }

}
EN

回答 1

Stack Overflow用户

发布于 2018-08-08 09:41:49

ServerConn中的msg变量从服务器读取时给出一个值,这个值不是在运行ServerConn对象的线程启动后立即给出的,当从ServerConn类获得msg时,需要在从ServerConn类调用的GUI线程上运行一些代码,在读取msg时,可以看到msg中有哪些值

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/-100001389

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档