http://blog.csdn.net/x605940745/article/details/17001641转载请注明出处

注意点：注册访问的网络权限；android中UI线程不能有访问网络的操作，否则会报android.os.NetworkOnMainThreadException的异常

[html] view plain copy

1. <uses-permission
2. android:name="android.permission.INTERNET"/>

Android开发联盟③ 433233634

实例一

客户端

[java] view plain copy

1. packagecom.android.xiong.simplesocket;
3. importjava.io.BufferedReader;
4. importjava.io.IOException;
5. importjava.io.InputStreamReader;
6. importjava.io.OutputStream;
7. importjava.net.InetSocketAddress;
8. importjava.net.Socket;
9. importjava.net.SocketTimeoutException;
11. importandroid.app.Activity;
12. importandroid.os.Bundle;
13. importandroid.os.Handler;
14. importandroid.os.Message;
15. importandroid.view.Menu;
16. importandroid.view.View;
17. importandroid.view.View.OnClickListener;
18. importandroid.widget.Button;
19. importandroid.widget.EditText;
20. importandroid.widget.TextView;
22. publicclassMainActivityextendsActivity{
23. Socketsocket=null;
24. Stringbuffer="";
25. TextViewtxt1;
26. Buttonsend;
27. EditTexted1;
28. Stringgeted1;
29. publicHandlermyHandler=newHandler(){
30. @Override
31. publicvoidhandleMessage(Messagemsg){
32. if(msg.what==0x11){
33. Bundlebundle=msg.getData();
34. txt1.append("server:"+bundle.getString("msg")+"\n");
35. }
36. }
38. };
40. @Override
41. protectedvoidonCreate(BundlesavedInstanceState){
42. super.onCreate(savedInstanceState);
43. setContentView(R.layout.activity_main);
44. txt1=(TextView)findViewById(R.id.txt1);
45. send=(Button)findViewById(R.id.send);
46. ed1=(EditText)findViewById(R.id.ed1);
47. send.setOnClickListener(newOnClickListener(){
49. @Override
50. publicvoidonClick(Viewv){
51. geted1=ed1.getText().toString();
52. txt1.append("client:"+geted1+"\n");
53. //启动线程向服务器发送和接收信息
54. newMyThread(geted1).start();
55. }
56. });
58. }
60. classMyThreadextendsThread{
62. publicStringtxt1;
64. publicMyThread(Stringstr){
65. txt1=str;
66. }
68. @Override
69. publicvoidrun(){
70. //定义消息
71. Messagemsg=newMessage();
72. msg.what=0x11;
73. Bundlebundle=newBundle();
74. bundle.clear();
75. try{
76. //连接服务器并设置连接超时为5秒
77. socket=newSocket();
78. socket.connect(newInetSocketAddress("1.1.9.30",30000),5000);
79. //获取输入输出流
80. OutputStreamou=socket.getOutputStream();
81. BufferedReaderbff=newBufferedReader(newInputStreamReader(
82. socket.getInputStream()));
83. //读取发来服务器信息
84. Stringline=null;
85. buffer="";
86. while((line=bff.readLine())!=null){
87. buffer=line+buffer;
88. }
90. //向服务器发送信息
91. ou.write("android客户端".getBytes("gbk"));
92. ou.flush();
93. bundle.putString("msg",buffer.toString());
94. msg.setData(bundle);
95. //发送消息修改UI线程中的组件
96. myHandler.sendMessage(msg);
97. //关闭各种输入输出流
98. bff.close();
99. ou.close();
100. socket.close();
101. }catch(SocketTimeoutExceptionaa){
102. //连接超时在UI界面显示消息
103. bundle.putString("msg","服务器连接失败！请检查网络是否打开");
104. msg.setData(bundle);
105. //发送消息修改UI线程中的组件
106. myHandler.sendMessage(msg);
107. }catch(IOExceptione){
108. e.printStackTrace();
109. }
110. }
111. }
113. @Override
114. publicbooleanonCreateOptionsMenu(Menumenu){
115. //Inflatethemenu;thisaddsitemstotheactionbarifitispresent.
116. getMenuInflater().inflate(R.menu.main,menu);
117. returntrue;
118. }
120. }

[html] view plain copy

1. <RelativeLayoutxmlns:android="http://schemas.android.com/apk/res/android"
2. xmlns:tools="http://schemas.android.com/tools"
3. android:layout_width="match_parent"
4. android:layout_height="match_parent"
5. android:paddingBottom="@dimen/activity_vertical_margin"
6. android:paddingLeft="@dimen/activity_horizontal_margin"
7. android:paddingRight="@dimen/activity_horizontal_margin"
8. android:paddingTop="@dimen/activity_vertical_margin"
9. tools:context=".MainActivity">
11. <EditText
12. android:id="@+id/ed1"
13. android:layout_width="match_parent"
14. android:layout_height="wrap_content"
15. android:hint="给服务器发送信息"/>
16. <Button
17. android:id="@+id/send"
18. android:layout_width="match_parent"
19. android:layout_height="wrap_content"
20. android:layout_below="@id/ed1"
21. android:text="发送"/>
22. <TextView
23. android:id="@+id/txt1"
24. android:layout_width="match_parent"
25. android:layout_height="wrap_content"
26. android:layout_below="@id/send"/>
31. </RelativeLayout>

服务端

[java] view plain copy

1. packagecom.android.net;
3. importjava.io.IOException;
4. importjava.net.ServerSocket;
5. importjava.net.Socket;
6. importjava.util.ArrayList;
7. importjava.util.List;
9. publicclassAndroidService{
12. publicstaticvoidmain(String[]args)throwsIOException{
13. ServerSocketserivce=newServerSocket(30000);
14. while(true){
15. //等待客户端连接
16. Socketsocket=serivce.accept();
17. newThread(newAndroidRunable(socket)).start();
18. }
19. }
21. }

[java] view plain copy

1. packagecom.android.net;
3. importjava.io.BufferedReader;
4. importjava.io.BufferedWriter;
5. importjava.io.IOException;
6. importjava.io.InputStream;
7. importjava.io.InputStreamReader;
8. importjava.io.OutputStream;
9. importjava.io.OutputStreamWriter;
10. importjava.io.PrintWriter;
11. importjava.net.Socket;
13. publicclassAndroidRunableimplementsRunnable{
15. Socketsocket=null;
17. publicAndroidRunable(Socketsocket){
18. this.socket=socket;
19. }
21. @Override
22. publicvoidrun(){
23. //向android客户端输出helloworild
24. Stringline=null;
25. InputStreaminput;
26. OutputStreamoutput;
27. Stringstr="helloworld!";
28. try{
29. //向客户端发送信息
30. output=socket.getOutputStream();
31. input=socket.getInputStream();
32. BufferedReaderbff=newBufferedReader(
33. newInputStreamReader(input));
34. output.write(str.getBytes("gbk"));
35. output.flush();
36. //半关闭socket
37. socket.shutdownOutput();
38. //获取客户端的信息
39. while((line=bff.readLine())!=null){
40. System.out.print(line);
41. }
42. //关闭输入输出流
43. output.close();
44. bff.close();
45. input.close();
46. socket.close();
48. }catch(IOExceptione){
49. e.printStackTrace();
50. }
52. }
53. }

实例二

客户端

[java] view plain copy

1. packagecom.android.xiong.sockettwotest;
3. importandroid.app.Activity;
4. importandroid.os.Bundle;
5. importandroid.os.Handler;
6. importandroid.os.Message;
7. importandroid.view.Menu;
8. importandroid.view.View;
9. importandroid.view.View.OnClickListener;
10. importandroid.widget.Button;
11. importandroid.widget.EditText;
12. importandroid.widget.TextView;
14. publicclassMainActivityextendsActivity{
16. //定义界面上的两个文本框
17. EditTextinput;
18. TextViewshow;
19. //定义界面上的一个按钮
20. Buttonsend;
21. Handlerhandler;
22. //定义与服务器通信的子线程
23. ClientThreadclientThread;
25. @Override
26. protectedvoidonCreate(BundlesavedInstanceState){
27. super.onCreate(savedInstanceState);
28. setContentView(R.layout.activity_main);
29. input=(EditText)findViewById(R.id.input);
30. show=(TextView)findViewById(R.id.show);
31. send=(Button)findViewById(R.id.send);
32. handler=newHandler(){
34. @Override
35. publicvoidhandleMessage(Messagemsg){
36. //如果消息来自子线程
37. if(msg.what==0x123){
38. //将读取的内容追加显示在文本框中
39. show.append("\n"+msg.obj.toString());
40. }
41. }
42. };
43. clientThread=newClientThread(handler);
44. //客户端启动ClientThread线程创建网络连接、读取来自服务器的数据
45. newThread(clientThread).start();
46. send.setOnClickListener(newOnClickListener(){
48. @Override
49. publicvoidonClick(Viewv){
50. try{
51. //当用户按下按钮之后，将用户输入的数据封装成Message
52. //然后发送给子线程Handler
53. Messagemsg=newMessage();
54. msg.what=0x345;
55. msg.obj=input.getText().toString();
56. clientThread.revHandler.sendMessage(msg);
57. input.setText("");
59. }catch(Exceptione){
61. }
62. }
63. });
64. }
66. @Override
67. publicbooleanonCreateOptionsMenu(Menumenu){
68. getMenuInflater().inflate(R.menu.main,menu);
69. returntrue;
70. }
72. }

[java] view plain copy

1. packagecom.android.xiong.sockettwotest;
3. importjava.io.BufferedReader;
4. importjava.io.IOException;
5. importjava.io.InputStreamReader;
6. importjava.io.OutputStream;
7. importjava.net.InetSocketAddress;
8. importjava.net.Socket;
9. importjava.net.SocketTimeoutException;
11. importandroid.os.Handler;
12. importandroid.os.Looper;
13. importandroid.os.Message;
15. publicclassClientThreadimplementsRunnable{
16. privateSockets;
17. //定义向UI线程发送消息的Handler对象
18. Handlerhandler;
19. //定义接收UI线程的Handler对象
20. HandlerrevHandler;
21. //该线程处理Socket所对用的输入输出流
22. BufferedReaderbr=null;
23. OutputStreamos=null;
25. publicClientThread(Handlerhandler){
26. this.handler=handler;
27. }
29. @Override
30. publicvoidrun(){
31. s=newSocket();
32. try{
33. s.connect(newInetSocketAddress("1.1.9.30",3000),5000);
34. br=newBufferedReader(newInputStreamReader(s.getInputStream()));
35. os=s.getOutputStream();
36. //启动一条子线程来读取服务器相应的数据
37. newThread(){
39. @Override
40. publicvoidrun(){
41. Stringcontent=null;
42. //不断的读取Socket输入流的内容
43. try{
44. while((content=br.readLine())!=null){
45. //每当读取到来自服务器的数据之后，发送的消息通知程序
46. //界面显示该数据
47. Messagemsg=newMessage();
48. msg.what=0x123;
49. msg.obj=content;
50. handler.sendMessage(msg);
51. }
52. }catch(IOExceptionio){
53. io.printStackTrace();
54. }
55. }
57. }.start();
58. //为当前线程初始化Looper
59. Looper.prepare();
60. //创建revHandler对象
61. revHandler=newHandler(){
63. @Override
64. publicvoidhandleMessage(Messagemsg){
65. //接收到UI线程的中用户输入的数据
66. if(msg.what==0x345){
67. //将用户在文本框输入的内容写入网络
68. try{
69. os.write((msg.obj.toString()+"\r\n")
70. .getBytes("gbk"));
71. }catch(Exceptione){
72. e.printStackTrace();
73. }
74. }
75. }
77. };
78. //启动Looper
79. Looper.loop();
81. }catch(SocketTimeoutExceptione){
82. Messagemsg=newMessage();
83. msg.what=0x123;
84. msg.obj="网络连接超时！";
85. handler.sendMessage(msg);
86. }catch(IOExceptionio){
87. io.printStackTrace();
88. }
90. }
91. }

[html] view plain copy

1. <RelativeLayoutxmlns:android="http://schemas.android.com/apk/res/android"
2. xmlns:tools="http://schemas.android.com/tools"
3. android:layout_width="match_parent"
4. android:layout_height="match_parent"
5. android:paddingBottom="@dimen/activity_vertical_margin"
6. android:paddingLeft="@dimen/activity_horizontal_margin"
7. android:paddingRight="@dimen/activity_horizontal_margin"
8. android:paddingTop="@dimen/activity_vertical_margin"
9. tools:context=".MainActivity">
11. <EditText
12. android:id="@+id/input"
13. android:layout_width="match_parent"
14. android:layout_height="wrap_content"
15. android:hint="@string/input"/>
16. <Button
17. android:id="@+id/send"
18. android:layout_width="match_parent"
19. android:layout_height="wrap_content"
20. android:text="@string/send"
21. android:layout_below="@id/input"/>
22. <TextView
23. android:id="@+id/show"
24. android:layout_width="match_parent"
25. android:layout_height="wrap_content"
26. android:layout_below="@id/send"/>
28. </RelativeLayout>

服务端

[java] view plain copy

1. packagecom.android.net;
3. importjava.io.IOException;
4. importjava.net.ServerSocket;
5. importjava.net.Socket;
6. importjava.util.ArrayList;
7. importjava.util.List;
9. publicclassMyService{
11. //定义保存所有的Socket
12. publicstaticList<Socket>socketList=newArrayList<Socket>();
14. publicstaticvoidmain(String[]args)throwsIOException{
15. ServerSocketserver=newServerSocket(3000);
16. while(true){
17. Sockets=server.accept();
18. socketList.add(s);
19. //每当客户端连接之后启动一条ServerThread线程为该客户端服务
20. newThread(newServiceThreada(s)).start();
22. }
23. }
25. }

[java] view plain copy

1. packagecom.android.net;
3. importjava.io.BufferedReader;
4. importjava.io.IOException;
5. importjava.io.InputStreamReader;
6. importjava.io.OutputStream;
7. importjava.net.Socket;
9. publicclassServiceThreadaimplementsRunnable{
11. //定义当前线程处理的Socket
12. Sockets=null;
13. //该线程所处理的Socket所对应的输入流
14. BufferedReaderbr=null;
16. publicServiceThreada(Sockets){
17. this.s=s;
18. try{
19. br=newBufferedReader(newInputStreamReader(s.getInputStream()));
20. }catch(IOExceptione){
21. e.printStackTrace();
22. }
23. }
25. @Override
26. publicvoidrun(){
28. Stringcontent=null;
29. //采用循环不断的从Socket中读取客户端发送过来的数据
30. while((content=readFromClient())!=null){
31. //遍历socketList中的每个Socket
32. //将读取到的内容每个向Socket发送一次
33. for(Sockets:MyService.socketList){
34. OutputStreamos;
35. try{
36. os=s.getOutputStream();
37. os.write((content+"\n").getBytes("gbk"));
38. }catch(IOExceptione){
39. //TODOAuto-generatedcatchblock
40. e.printStackTrace();
41. }
43. }
44. }
46. }
48. //定义读取客户端的信息
49. publicStringreadFromClient(){
50. try{
51. returnbr.readLine();
52. }catch(Exceptione){
53. e.printStackTrace();
54. }
55. returnnull;
56. }
58. }

更多相关文章

1. 万字长文带你了解最常用的开源 Squid 代理服务器
2. Nginx系列教程（一）| 手把手教你在Linux环境下搭建Nginx服务
3. Nginx系列教程（二）| 一文带你读懂Nginx的正向与反向代理
4. Nginx系列教程（三）| 一文带你读懂Nginx的负载均衡
5. RHEL 6 下 DHCP+TFTP+FTP+PXE+Kickstart 实现无人值守安装
6. android报The content of the adapter has changed but ListView
7. Android(安卓)HandlerThread详解
8. Android(安卓)Toast 总结
9. Android(安卓)反序列化异常EOFException的解决

随机推荐

1. 关于android各种双卡手机获取imei，imsi的
2. 2016年末，Android岗位BAT等大厂面试题知识
3. Android(安卓)Studio不识别新安装的字体
4. Android实战项目——音乐播放器 由四大组
5. 设置Android沉浸式状态栏颜色以及更改字
6. Android理解四种启动模式
7. android/ophone 横竖屏切换问题的解决方
8. 不同手机在豌豆夹上显示设备同名的解决方
9. MoDaCo.Switch 让你的 HTC One 自由转换
10. android 集成系统分享和第三方分享案例