在Android上使用Socket

2022-03-01 06:18:41

原文地址：http://www.cnblogs.com/kross/p/3621952.html

考虑到以后可能要用到这方面的知识，就来写个Demo尝试下，其实以前学过，但不记得了……（用不到的东西各种不记得啊）

直接进入正题吧，在Android上使用Socket实际上跟在Java中使用差不多，只要注意下在Manifest中加网络权限就好了（我原来经常犯这个错误），另外网络请求不能再主线程里，基本就OK了。

そして，先写一个服务器的小程序吧。就直接使用Java写就好了，灰常的简单，随便写写。

/**
 * 测试服务器
 * */
public class TestServer {

    public static void main(String[] args) throws IOException {
        
        ServerSocket ss = new ServerSocket(5417);
        
        Socket client = null;
        
        while (true) {
            System.out.println("waiting for...");
            client = ss.accept();
            BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
            System.out.println(br.readLine());
        }
    }
}

然后我的构想是，手机上有一个输入框，一个按钮，用户可以按按钮，把输入框里的内容发送到服务器上。一开始我写了一个很混乱的demo，为了更加方便使用，就把Socket的封装了一下，就叫SocketManager吧，代码如下：

/**
 * SocketManager，简单的封装了一下
 * @author Kross(krossford@foxmail.com)
 * @date 2014-3-24 21:39:48
 * */
public class SocketManager {
    
    private Socket client = null;
    
    //服务器的IP地址
    private String ip = "113.251.172.30";
    
    //监听的端口号
    private int port = 5417;
    
    /**
     * 获取一个实例
     * */
    public static SocketManager newInstance() throws UnknownHostException, IOException {
        return new SocketManager();
    }
    
    private SocketManager() throws UnknownHostException, IOException {
        client = new Socket(ip, port);
    }
    
    /**
     * 发送一条消息
     * @param msg 消息内容
     * */
    public void sendMessage(String msg) throws IOException {
        PrintWriter printWriter = new PrintWriter(client.getOutputStream());
        printWriter.print(msg);
        printWriter.flush();
        printWriter.close();    //一定要关闭输出流，要不然消息无法送达到服务器
    }
}

几个要点：

1.IP地址就写Java程序锁运行的机器的公网地址，cmd->ipconfig就可以查到。

2.端口号请和服务器那个保持一致，都不在一个管道里怎么通信哇。

3.我使用了静态工厂方法，每次都要重新new一个SocketManager，因为我发现Socket这个类只能用一次，close之后再发送便没用了。

4.服务器要收到信息，必须要客户端的东西close了，输出流close也好，socket.close也好，总之要close，服务器才能确切的收到。

然后，我写了一个线程来执行这个Socket，因为不能在主线程跑嘛，我想了很久，可不可以让这个线程一直执行着，然后只要调用下这个线程的sendMessage方法，就可以发送了，这样就只需要new一个线程就行了，但是我想了好久，都想不通，貌似不能那样，线程要么没有，有的话就会一股脑的执行它的run()方法，想要长时间持有它？在run里面加个while(true)？那怎么做到调用它的共有方法呢？总之，我没有想到用只需要new一个线程就可以发N个请求的办法，貌似需要使用到Service来实现了。

/**
 * 发起请求的线程
 * @author Kross(krossford@foxmail.com)
 * @date 2014-3-24 21:40:21
 * */
public class SocketThread implements Runnable {
    
    private String message;
    
    public SocketThread(String msg) {
        message = msg;
    }
    
    @Override
    public void run() {
        try {
            SocketManager.newInstance().sendMessage(message);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

这里倒没什么好说的。接下来我们就直接在MainActivity里面准备好控件，监听器，然后就OK了，大致的看下代码吧。

public class MainActivity extends Activity {
    
    private EditText etInput = null;
    private Button bSend = null;
    
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        Log.i("MainActivity", Thread.currentThread().getName());
        
        etInput = (EditText)findViewById(R.id.et_input);
        bSend = (Button)findViewById(R.id.b_send);
        
        bSend.setOnClickListener(new SendButtonListener());
        
    }
    
    class SendButtonListener implements OnClickListener {

        @Override
        public void onClick(View v) {
            String msg = etInput.getEditableText().toString().trim();
            new Thread(new SocketThread(msg)).start();
            etInput.setText("");
        }
    }
}