Android连接服务器端的Socket的实例代码-创新互联
废话不多说了,直接给大家贴代码了,具体代码如下所述:
专注于为中小企业提供成都网站设计、成都网站建设服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业富阳免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了上1000家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。package com.exa
mple.esp8266; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintStream; import java.net.Socket; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.Toast; public class MainActivity extends Activity { private EditText edSend, edReceive; private Button btnConnect, btnSend; private Handler myHandler; private SendThread SendThread; private boolean isReceive = false; private boolean isConnect = false; private static final String HOST = "192.168.4.1"; private static final int PORT = 333; String strMessage; Socket socket = null; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); edSend = (EditText) findViewById(R.id.edSend); edReceive = (EditText) findViewById(R.id.edReceive); btnConnect = (Button) findViewById(R.id.btConnect); btnSend = (Button) findViewById(R.id.btSend); // 连接 btnConnect.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { // TODO Auto-generated method stub if (!isConnect) { new Thread(connectThread).start(); isConnect = true; } } }); // 发送 btnSend.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { // 启动发送线程 new Thread(SendThread).start(); } }); myHandler = new Handler() {// UI主线程消息处理函数 public void handleMessage(Message msg) { Bundle bundle = msg.getData(); String string = bundle.toString(); edReceive.setText(string); } }; } // 连接到服务器的接口 Runnable connectThread = new Runnable() { public void run() { // TODO Auto-generated method stub try { socket = new Socket(HOST, PORT); if (socket != null) Toast.makeText(getApplicationContext(), "连接成功", Toast.LENGTH_LONG).show(); else Toast.makeText(getApplicationContext(), "连接失败", Toast.LENGTH_LONG).show(); // 初始化发送线程 SendThread = new SendThread(socket); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }; // 接收消息的接口 Runnable Receive = new Runnable() { InputStream inStream; private byte[] buffer; private String str = null; public void run() { // TODO Auto-generated method stub while (!isReceive) { buffer = new byte[512]; try { inStream = socket.getInputStream(); inStream.read(buffer); } catch (IOException e) { e.printStackTrace(); } str = new String(buffer); Bundle bundle = new Bundle(); bundle.get(str); Message message = new Message(); message.setData(bundle); myHandler.sendMessage(message); } } }; // 发送线程 private class SendThread extends Thread { private OutputStream outStream = null; private String str = null; SendThread(Socket socket) { try { outStream = socket.getOutputStream(); } catch (IOException e) { e.printStackTrace(); } } public void run() { // while(true){ str = edSend.getText().toString().trim(); PrintStream pt = new PrintStream(outStream); pt.print(str); new Thread(Receive).start(); // } } } protected void onDestroy() { // TODO Auto-generated method stub super.onDestroy(); if (Receive != null) { isReceive = false; ((Thread) Receive).interrupt(); } } }
本文题目:Android连接服务器端的Socket的实例代码-创新互联
浏览地址:http://cdiso.cn/article/shcod.html