这方面的知识不是孤立的，其中有关于，socket编程，多线程的操作，以及i/o流的操作。当然，实现方法不止一种，这只是其中一种，给同是新手一点点思路。如果有什么推荐的话，欢迎指点！
先给大家看一下应用程序的界面，基本就能知道大致的功能了。
activity_main.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
<linearlayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical" tools:context=".mainactivity"> <edittext android:id="@+id/edittext" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="请输入要发送的内容"/> <button android:id="@+id/button01" android:layout_width="match_parent" android:layout_height="wrap_content" android:text="连接"/> <button android:id="@+id/button02" android:layout_width="match_parent" android:layout_height="wrap_content" android:text="发送"/> <scrollview android:layout_width="match_parent" android:layout_height="wrap_content" android:scrollbars="vertical" android:fadingedge="vertical"> <textview android:id="@+id/textview" android:layout_width="match_parent" android:layout_height="wrap_content" android:text="输出信息:"/> </scrollview></linearlayout> |
界面很是简单。
下面我们需要一个服务器，和一个客户端。服务器，我用的是eclipse写的java的服务器；客户端，我用的是android studio写的。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
package com.ryan.socketdemo01;import android.os.handler;import android.os.message;import android.support.v7.app.appcompatactivity;import android.os.bundle;import android.util.log;import android.view.menu;import android.view.menuitem;import android.view.view;import android.widget.button;import android.widget.edittext;import android.widget.textview;import android.widget.toast;import java.io.ioexception;import java.io.outputstream;import java.io.unsupportedencodingexception;import java.net.socket;/** * 本实例功能： 客户端发送数据至客户端（动态输出数据） * */public class mainactivity extends appcompatactivity implements view.onclicklistener{ private button button01 = null; private button button02 = null; private edittext edittext = null; private textview textview = null; private static socket clientsocket = null; private byte[] msgbuffer = null; handler handler = new handler(); private void initview() { button01 = (button) findviewbyid(r.id.button01); button02 = (button) findviewbyid(r.id.button02); edittext = (edittext) findviewbyid(r.id.edittext); textview = (textview) findviewbyid(r.id.textview); button01.setonclicklistener(this); button02.setonclicklistener(this); button01.setenabled(true); button02.setenabled(false); } @override protected void oncreate(bundle savedinstancestate) { super.oncreate(savedinstancestate); setcontentview(r.layout.activity_main); initview(); } @override public void onclick(view v) { switch (v.getid()){ case r.id.button01: // todo: 15-9-4 socket连接线程 connectthread(); break; case r.id.button02: // todo: 15-9-4 发送数据线程 sendmsgthread(); break; } } private void sendmsgthread() { final string text = edittext.gettext().tostring(); try { msgbuffer = text.getbytes("utf-8"); } catch (unsupportedencodingexception e) { e.printstacktrace(); } new thread(new runnable() { @override public void run() { try { outputstream outputstream; //socket输出流 outputstream = clientsocket.getoutputstream(); outputstream.write(msgbuffer); outputstream.flush(); outputstream.close(); } catch (ioexception e) { e.printstacktrace(); } handler.post(new runnable() { @override public void run() { textview.append("发送成功："+text+"\n"); } }); } }).start(); } private void connectthread() { new thread(new runnable() { @override public void run() { try { clientsocket = new socket("10.0.2.2",9001); if (clientsocket.isconnected()){ handler.post(new runnable() { @override public void run() { textview.append("连接成功！"+"\n"); button01.setenabled(false); button02.setenabled(true); } }); }else { handler.post(new runnable() { @override public void run() { textview.append("连接失败！"+"\n"); } }); } } catch (ioexception e) { e.printstacktrace(); } } }).start(); } |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
@override public boolean oncreateoptionsmenu(menu menu) { // inflate the menu; this adds items to the action bar if it is present. getmenuinflater().inflate(r.menu.menu_main, menu); return true; } @override public boolean onoptionsitemselected(menuitem item) { // handle action bar item clicks here. the action bar will // automatically handle clicks on the home/up button, so long // as you specify a parent activity in androidmanifest.xml. int id = item.getitemid(); //noinspection simplifiableifstatement if (id == r.id.action_settings) { return true; } return super.onoptionsitemselected(item); }} |
这里我的线程使用方式是：
|
1
2
3
4
5
|
new thread (new runnable) { @override public void run() { } } |
网上有人说这个方式很low，而且不好，但现在我只会这个，就连asynctask也还在学习中。
还有一点，子线程更新主ui的方法：
我使用的是 handler.post(); 同样十分简单的使用方法。
|
1
2
3
4
5
6
7
8
9
|
handler handler = new handler(); handler.post(new runnable() { @override public void run() { textview.append("发送成功："+text+"\n"); } }); |
关于几种子线程更新主ui的方法，我以后会再写一篇博客。我现在已经知道了不下4中方法，还没实地操作。
再来就是关于i/o流操作的方法：
这里我不做详细介绍，大家自行google！什么你不会google？ 自行找fq工具吧～～
这里我说一下我对于i/o的简单使用方法。
万物始于最初的，inputstream，outputstream，他的方法只有reader()和write()。再其之上的，例如什么使用最多的bufferedreader对象，都是再其之上的升级包装，穿了个衣服，变得更加华丽而已。他的专业术语就是——装饰者模式，感兴趣的可以去翻翻资料。
最初，我对inputstream和outputstream的方法不是很明了，经常错将inputstream用上write()的方法。 不知在哪里看到这么一段话，i/o流的操作实质是相对于socket，serversocket连接后产生的数据流管道，reader与write是读取与写入的意思，是相对于那个数据流管道进行操作的。即读取管道里的信息，写入信息至管道。不知道这样大家动不动。
最后就是我们要学习的socket。
他的使用也很简单，建立一个socket对象，设置ip和端口，获取其i/o流。
|
1
2
3
|
clientsocket = new socket("10.0.2.2",9001);outputstream = clientsocket.getoutputstream(); |
到这里基本的使用方法就这么多。
说说我在这其中遇到的问题：
1.模拟器连接java服务器连接不上。ip设置不对，我最开始设置的ip是 127.0.0.1。 解决的连接：
http://stackoverflow.com/questions/8191192/reaching-a-network-device-by-ip-and-port-using-the-android-emulator/8191487#8191487
2.忘记设置manifest，或者系统提供的android.permission.internet全是大写的！！说来滑稽，但我就是遇到这样的问题，系统自动完成的代码提示，全是大写的，我以为就是那样呢，结果明明应该是小写。
<uses-permission android:name="android.permission.internet" />
忘记贴上java服务器的代码了，补上。
|
1
2
3
4
5
6
7
8
9
10
11
|
/** * 本实例功能：接受服务器发来的数据 */public class main { public static void main(string[] args) { // todo auto-generated method stub new serverlistener().start(); }} |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
import java.io.bufferedreader;import java.io.ioexception;import java.io.inputstream;import java.io.inputstreamreader;import java.io.unsupportedencodingexception;import java.net.serversocket;import java.net.socket;import javax.swing.joptionpane;public class serverlistener extends thread{ private socket clientsocket = null; private serversocket serversocket = null; private inputstream inputstream = null; private byte[] buffer = null; @override public void run() { // todo auto-generated method stub try { serversocket = new serversocket(9001); system.out.println("端口已开启，等待连接中〜〜"); //block clientsocket = serversocket.accept(); system.out.println("已有用户连接"); inputstream = clientsocket.getinputstream(); bufferedreader br = new bufferedreader(new inputstreamreader(inputstream)); string str; while((str = br.readline())!= null){ system.out.println(str); } }catch (ioexception e) { // todo auto-generated catch block e.printstacktrace(); }finally{ try { inputstream.close(); serversocket.close(); } catch (ioexception e) { // todo auto-generated catch block e.printstacktrace(); } } }} |
这是服务器端就收到的数据：
ok，基本就这样。
以上就是本文的全部内容，希望对大家的学习有所帮助。
