[资料]

android 通信机制 socket

2014-1-9 22:36:41 2992

0 socket 作为一种通信机制，可以实现单机或者跨网络之间的通信，要有明确的server端和client端。 android里面最简单的socket 通信的demo： //1. IP 地址 InetAddress inetAddress =InetAddress.getByName("IP address"); // socket port Socket client = newSocket(inetAddress,61203,true); // get data stream InputStream in =client.getinputStream(); OutputStream out =client.getOutputStream(); // deal with data // close connection out.close(); in.close(); client.close(); 　　在一个完整的通行过程，包括2个socket，一个server段在用，另外一个是client段。整个架构的简介：　　　　1）通常情况下，我们使用线程处理socket携带的信息。　　　　2）clientThread， serverThread处理socket，好处是主线程可以继续其他的工作。　　demo创建的流程：1. 在Eclipse里面安装Tomcat 作为server 　　　　　　　　　　　2. 编写一个service project用来处理client 传递过来的数据，并且把处理过的数据返回到客户端　　　　　　　　　　　3. 编写一个简单的android应用，向service发送数据，并且接收service返回的数据　　1. 如何在Eclipse里面配置Tomcat不是本文的重点，在网上搜索一堆。这里要说明的如果默认的8080端口被使用，要修改Tomcat配置文件里面的端口号，配置文件的地址是../conf/server.xml 　这个只是Tomcat的端口，和socket里面的端口不一样。　　2. Server的端代码：　　　1）ServerThread 　　publicclass SeverThread implements Runnable 　　{ 　　　　privateSocket socket=null; // 定义一个socket 给当前线程使用　　　　privateBufferedReader br=null; // 处理线程里面socket所对应的输入流　　　　publicServerThread（Socket socket）　　　　{ 　　　　　　this.socket=socket; 　　　　　　// 初始化socket对应的流　　　　　　br = newBufferedReader(newInputStreamReader(socket.getInputStream(),"utf-8")); 　　　　} 　　　　publicvoid run() 　　　　{ 　　　　　　Stringcontent=""; 　　　　　　// 不停的loop，读取client传过的数据　　　　　　while((content= getContent())!= null){ 　　　　　　　　// 读取socket里面的内容，然后回发, 这里是整个server的核心，也是功能扩展的核心　　　　　　　　for(Sockets : MyServer.socketList){ 　　　　　　　　　　OutputStreamos = s.getOutputStream(); // outputStream 是用socket创建　　　　　　　　　　os.write(("这个server段给你的消息").getBytes("utf-8")) 　　　　　　　　} 　　　　　　} 　　　　} 　　　　privateString getContent() 　　　　{ 　　　　　　try{ 　　　　　　　　　　returnbr.readLine(); 　　　　　　　　}catch(Exceptionex){ 　　　　　　　　　　MyServer.socketList.remove(socket);//如果捕获到异常，表明要关闭这个client的连接，删除该socket 　　　　　　　　} 　　　　　　　　returnnull; 　　　　} 　　} 定义好一个serverThread，我们就开始在编写service app，定义一个简单的控制台应用即可，host在tomcat上。 public class MyServer{ 　　publicList socketList = new ArrayList(); 　　publicstatic void main(){ 　　　　ServerSocketss = new ServerSocket(18070) ;// 这里的18070是端口号，这个是client 和server 公用的端口号　　　　// 程序开始不停的loop，等待client的连接　　　　while(true){ 　　　　　　Socket s= ss.accept(); 　　　　　　socketList.add(s); 　　　　　　// 有client的socket过来的时候启动线程处理　　　　　　newThread(new ServerThread(s)).start(); 　　　　} 　　} } 至此server段的代码已经编写完毕，启动Tomcat，启动server的application host在Tomcat上，一个完整的service已经好了。　　3. 编写client段， client段的结构和server类似，一个clientThread，一个android application public class ClientThread implementsRunnable{ 　　privateSocket socket; //为这个线程定义一个socket　　　privateBufferedReader br = null;// 处理该线程的socket流　　privateHandler handler;// 作用是发送message到UI，通知UI改变信息　　public ClientThread(Socketsocket, Handler handler) throw IOException 　　{ 　　　　this.socket = socket; 　　　　this.handler=handler; 　　　　br=newBufferedReader(new InputStreamReader(sockt.getInputStream())); 　　} 　　publicvoid run(){ 　　　　try{ 　　　　　　Stringcontent=""; 　　　　　　// 和server相同，不停的循环读取socket里面的流　　　　　　while((content=br.readLine())!=null){ 　　　　　　　　　　// 读到数据之后，发送message，通知UI改变　　　　　　　　　　Messagemsg = new Message(); 　　　　　　　　　　msg.what=0X123;// 作为message的标识　　　　　　　　　　msg.object=content; 　　　　　　　　　　handler.sendMessage(msg); 　　　　　　} 　　　　}catch(Exceptionex){ 　　　　　　e.printStackTrace(); 　　　　} 　　} } public class MainActivity extendsActivity implements Runnable { privateButton btnTest; private TextView tv_msg; private EditText etMessage; private String content = ""; Handler handler; // 需要BufferedReader BufferedReader bufferedReader = null; // 需要一个socket Socket socket = null; // 需要一个printWritter PrintWriter out = null; OutputStream os; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); // 如果是2.3以后的版本，这段必须加上 StrictMode.setThreadPolicy(new StrictMode.ThreadPolicy.Builder() .detectDiskReads().detectDiskWrites().detectNetwork() / .penaltyLog().build()); StrictMode.setVmPolicy(new StrictMode.VmPolicy.Builder() .detectLeakedSqlLiteObjects().penaltyLog().penaltyDeath() .build()); handler = new Handler() { @Override public void handleMessage(Message msg) { // 如果消息来自于子线程 if (msg.what == 0x123) { // 将读取的内容追加显示在文本框中 tv_msg.append("n" + msg.obj.toString()); } } }; initalView(); btnTest.setOnClickListener(myListener); new Thread(MainActivity.this).start(); } privatevoid initalView() { btnTest = (Button) findViewById(R.id.btnTest); etMessage = (EditText) findViewById(R.id.messageET); tv_msg = (TextView) findViewById(R.id.tv_msg); initalSocket(); } privatevoid initalSocket() { try { socket = new Socket(); InetSocketAddress sd = new InetSocketAddress(HostPort.HOST,HostPort.PORT); socket.connect(sd,5000); new Thread(new ClientThread(socket, handler)).start(); // ① os = socket.getOutputStream(); } catch (UnknownHostException e) { // 由于会发生断网什么的异常处理 System.out.print("连接不上了"); e.printStackTrace(); } catch (IOException e) { System.out.print(e.getMessage()); e.printStackTrace(); } } private View.OnClickListenermyListener = new View.OnClickListener() { @Override public void onClick(View v) { switch (v.getId()) { case R.id.btnTest: testSocket(); break; } } }; privatevoid testSocket() { // 将用户在文本框内输入的内容写入网络 try { os.write((etMessage.getText().toString() + "rn") .getBytes("utf-8")); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } // 清空input文本框 etMessage.setText(""); } @Override public void run() { } @SuppressLint("HandlerLeak") public Handler mHandler = new Handler() { public void handleMessage(Message msg) { super.handleMessage(msg); Log.println(1, "test", msg.toString()); tv_msg.setText(tv_msg.getText().toString() + content); } }; } 同时在manifest.xml文件中添加权限启动androidapplication 即可用socket通行。以上这种方式其实质就是TCP/IP协议的网络通信。 TCP/IP通信的运行机制是首先向对方发出询问，在等到对方的response后，就给对方发数据。 0
举报淘帖0 只看该作者相关推荐 • CH579网络库内有没有做断开socket连接机制？ 430 • 如何用Android Studio去创建Socket客户端呢 645 • socket通信该怎样去实现呢 1949 • Android学习笔记（二）实现与单片机的TCP通信app 精选资料分享 674 • 浅析Java socket通信 837 • Linux之本地Socket通信 3050 • linux与android怎么socket通信 3130 • 如何通过Socket通信控制LED 10891 • Android Socket通信客户端 2320 • 基于OK6410 android下socket通信 3269