1.客户端代码实现
首先创建一个Android应用,名称:AndroidSocketTest
然后分别创建4个文件:BytesUtil.java、BytesReader.java、BytesWriter.java、TCPCommunication.java,下面分别介绍这几个文件的用处和源码:
BytesUtil.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
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
<code>/**</code>
<code>author:alexzhou</code>
<code>email :[email protected]</code>
<code>date :2012-11-7</code>
<code> </code><code>**/</code>
<code>public</code>
<code>final</code> <code>class</code> <code>BytesUtil {</code>
<code> </code><code>/**</code>
<code> </code><code>*整型转换成字节数组</code>
<code> </code><code>* @param value 要转换的整型值</code>
<code> </code><code>* @return</code>
<code> </code><code>*/</code>
<code> </code><code>public</code>
<code>static</code> <code>byte</code><code>[] shortToBytes(</code><code>int</code>
<code>value) {</code>
<code> </code><code>byte</code>
<code>[]write =</code><code>new</code>
<code>byte</code><code>[</code><code>2</code><code>];</code>
<code> </code><code>write[</code><code>0</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>8</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>0</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>return</code>
<code>write;</code>
<code> </code><code>}</code>
<code>static</code> <code>byte</code><code>[] intToBytes(</code><code>int</code>
<code>byte</code><code>[</code><code>4</code><code>];</code>
<code> </code><code>write[</code><code>0</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>24</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>16</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>2</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>8</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>3</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>0</code><code>) &</code><code>0xFF</code><code>);</code>
<code>static</code> <code>byte</code><code>[] longToBytes(</code><code>long</code>
<code>byte</code><code>[</code><code>8</code><code>];</code>
<code> </code><code>write[</code><code>0</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>56</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>48</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>2</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>40</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>3</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>32</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>4</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>24</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>5</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>16</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>6</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>8</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>write[</code><code>7</code><code>] = (</code><code>byte</code><code>)( (value >>></code><code>0</code><code>) &</code><code>0xFF</code><code>);</code>
<code> </code><code>* 字节数组转换成整型</code>
<code> </code><code>* @param value</code>
<code>static</code> <code>int</code> <code>bytesToInt(</code><code>byte</code>
<code>[]value) {</code>
<code> </code><code>int</code>
<code>i1 = (value[</code><code>0</code><code>] &</code><code>0xFF</code><code>) <<</code><code>24</code><code>;</code>
<code>i2 = (value[</code><code>1</code><code>] &</code><code>0xFF</code><code>) <<</code><code>16</code><code>;</code>
<code>i3 = (value[</code><code>2</code><code>] &</code><code>0xFF</code><code>) <<</code><code>8</code><code>;</code>
<code>i4 = (value[</code><code>3</code><code>] &</code><code>0xFF</code><code>) <<</code><code>0</code><code>;</code>
<code>(i1 | i2 | i3 | i4);</code>
<code>static</code> <code>short</code> <code>bytesToShort(</code><code>byte</code><code>[] value) {</code>
<code>s1 = (value[</code><code>0</code><code>] &</code><code>0xFF</code><code>) <<</code><code>8</code><code>;</code>
<code>s2 = (value[</code><code>1</code><code>] &</code><code>0xFF</code><code>) <<</code><code>0</code><code>;</code>
<code>(</code><code>short</code><code>)(s1 | s2);</code>
<code>static</code> <code>long</code> <code>bytesToLong(</code><code>byte</code><code>[] value) {</code>
<code> </code><code>long</code>
<code>L1 = (value[</code><code>0</code><code>] &</code><code>0xFF</code><code>) <<</code><code>56</code><code>;</code>
<code>L2 = (value[</code><code>1</code><code>] &</code><code>0xFF</code><code>) <<</code><code>48</code><code>;</code>
<code>L3 = (value[</code><code>2</code><code>] &</code><code>0xFF</code><code>) <<</code><code>40</code><code>;</code>
<code>L4 = (value[</code><code>3</code><code>] &</code><code>0xFF</code><code>) <<</code><code>32</code><code>;</code>
<code>L5 = (value[</code><code>4</code><code>] &</code><code>0xFF</code><code>) <<</code><code>24</code><code>;</code>
<code>L6 = (value[</code><code>5</code><code>] &</code><code>0xFF</code><code>) <<</code><code>16</code><code>;</code>
<code>L7 = (value[</code><code>6</code><code>] &</code><code>0xFF</code><code>) <<</code><code>8</code><code>;</code>
<code>L8 = (value[</code><code>7</code><code>] &</code><code>0xFF</code><code>) <<</code><code>0</code><code>;</code>
<code>(L1 | L2 | L3 | L4 | L5 | L6 | L7 | L8);</code>
<code> </code><code>* 从指定字节数组中拷贝部分数据</code>
<code> </code><code>* @param origin</code>
<code> </code><code>* @param from</code>
<code> </code><code>* @param to</code>
<code>static</code> <code>byte</code><code>[] copyBytes(</code><code>byte</code><code>[] origin,</code><code>int</code>
<code>from,</code><code>int</code>
<code>to) {</code>
<code>len = to - from;</code>
<code> </code><code>if</code><code>(len <</code><code>0</code>
<code>|| origin.length - from <=</code><code>0</code><code>) {</code>
<code> </code><code>throw</code>
<code>new</code> <code>IllegalArgumentException(</code><code>"copyBytes->error arguments:to="</code><code>+to+</code><code>",from="</code><code>+from);</code>
<code> </code><code>}</code>
<code> </code><code>byte</code><code>[] ret =</code><code>new</code>
<code>byte</code><code>[len];</code>
<code> </code><code>if</code><code>(len ==</code><code>0</code><code>)</code><code>return</code>
<code>ret;</code>
<code> </code><code>System.arraycopy(origin, from, ret,</code><code>0</code><code>, Math.min(len, origin.length - from));</code>
<code> </code><code>* 重置字节数组的大小,然后把原内容复制到新的字节数组中</code>
<code> </code><code>* @param newSize</code>
<code>static</code> <code>byte</code><code>[] resizeBytes(</code><code>byte</code><code>[] origin,</code><code>int</code>
<code>newSize) {</code>
<code> </code><code>if</code><code>(newSize <</code><code>0</code><code>) {</code>
<code>new</code> <code>IllegalArgumentException(</code><code>"resizeBytes->newSize must >= 0"</code><code>);</code>
<code>byte</code><code>[newSize];</code>
<code> </code><code>if</code><code>(newSize ==</code><code>0</code><code>)</code><code>return</code>
<code> </code><code>System.arraycopy(origin,</code><code>0</code><code>,ret,</code><code>0</code><code>,Math.min(origin.length, newSize));</code>
<code> </code><code>* 读取输入流中字节,并保存到指定的字节数组中</code>
<code> </code><code>* @param is</code>
<code> </code><code>* @param data</code>
<code> </code><code>* @param off</code>
<code> </code><code>* @param len</code>
<code>static</code> <code>void</code> <code>readData(InputStream is,</code><code>byte</code>
<code>data[],</code><code>int</code>
<code>off,</code><code>int</code>
<code>len) {</code>
<code>hasRead =</code><code>0</code><code>;</code>
<code> </code><code>final</code>
<code>int</code> <code>BUFFER =</code><code>1024</code><code>;</code>
<code> </code><code>while</code><code>(hasRead < len) {</code>
<code> </code><code>try</code>
<code>{</code>
<code> </code><code>int</code>
<code>remain = len - hasRead;</code>
<code>count = is.read(data, off + hasRead, remain > BUFFER ? BUFFER : remain);</code>
<code> </code><code>if</code><code>(count <</code><code>0</code><code>)</code><code>throw</code>
<code>new</code> <code>IOException(</code><code>"readData->read data error"</code><code>);</code>
<code> </code><code>hasRead += count;</code>
<code> </code><code>}</code><code>catch</code>
<code>(IOException e) {</code>
<code> </code><code>e.printStackTrace();</code>
<code> </code><code>}</code>
<code>}</code>
BytesReader.java:从服务端接收数据时使用,定义了一个字节数组类型的成员变量,用来保存从输入流中读取的数据。封装了一些从该字节数组中读取相应数据类型的函数,源码如下:
<code> </code><code>* 接受服务端数据时,读取字节并转换到相应类型</code>
<code>final</code> <code>class</code> <code>BytesReader {</code>
<code> </code><code>private</code>
<code>final</code> <code>byte</code> <code>[]data;</code>
<code> </code><code>//字节数组的大小</code>
<code>final</code> <code>int</code> <code>size;</code>
<code> </code><code>//当前读取的位置</code>
<code>int</code> <code>position;</code>
<code>BytesReader(</code><code>byte</code>
<code>[]data) {</code>
<code> </code><code>this</code><code>.data = data;</code>
<code> </code><code>this</code><code>.size = data.length;</code>
<code> </code><code>this</code><code>.position =</code><code>0</code><code>;</code>
<code>byte</code><code>[] read(</code><code>int</code>
<code> </code><code>if</code><code>(len <</code><code>0</code><code>)</code><code>return</code>
<code>null</code><code>;</code>
<code> </code><code>byte</code><code>[] value = BytesUtil.copyBytes(data, position, position + len);</code>
<code> </code><code>this</code><code>.position += len;</code>
<code>value;</code>
<code>int</code> <code>getSize() {</code>
<code>size;</code>
<code>boolean</code> <code>isAvailable() {</code>
<code>size - position ></code><code>0</code><code>;</code>
<code>short</code> <code>readShort() {</code>
<code> </code><code>byte</code><code>[] value = read(</code><code>2</code><code>);</code>
<code>BytesUtil.bytesToShort(value);</code>
<code>int</code> <code>readInt() {</code>
<code> </code><code>byte</code><code>[] value = read(</code><code>4</code><code>);</code>
<code>BytesUtil.bytesToInt(value);</code>
<code>long</code> <code>readLong() {</code>
<code> </code><code>byte</code><code>[] value = read(</code><code>8</code><code>);</code>
<code>BytesUtil.bytesToLong(value);</code>
<code>byte</code> <code>readByte() {</code>
<code>value =</code><code>this</code><code>.isAvailable() ? (</code><code>0xFF</code>
<code>& data[position++]) : -</code><code>1</code><code>;</code>
<code>(</code><code>byte</code><code>)value;</code>
<code>byte</code><code>[] readBytes() {</code>
<code>len = readShort();</code>
<code> </code><code>//读取大数据</code>
<code> </code><code>if</code><code>(len >=</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>len =</code><code>this</code><code>.readInt();</code>
<code>len ==</code><code>0</code>
<code>?</code><code>null</code>
<code>: read(len);</code>
<code>String readUTF() {</code>
<code> </code><code>byte</code><code>[] bytes = readBytes();</code>
<code> </code><code>if</code><code>(</code><code>null</code>
<code>!= bytes) {</code>
<code> </code><code>return</code>
<code>new</code> <code>String(bytes,</code><code>"UTF-8"</code><code>);</code>
<code>(UnsupportedEncodingException e) {</code>
BytesWriter.java:向服务端发送数据时使用,跟BytesReader.java对应,也是把需要发送的数据保存到字节数组中,然后一次性发送给服务器。源码如下:
<code>date :2012-11-9</code>
<code>final</code> <code>class</code> <code>BytesWriter {</code>
<code>byte</code><code>[] data;</code>
<code>int</code> <code>count;</code>
<code>BytesWriter() {</code>
<code> </code><code>this</code><code>(</code><code>64</code><code>);</code>
<code>BytesWriter(</code><code>int</code>
<code>size) {</code>
<code> </code><code>this</code><code>.data =</code><code>new</code>
<code>byte</code><code>[size];</code>
<code>byte</code><code>[] getBytes() {</code>
<code>this</code><code>.data.length == count ? data : count ==</code><code>0</code>
<code>: BytesUtil.resizeBytes(</code><code>this</code><code>.data, count);</code>
<code>void</code> <code>write(</code><code>byte</code><code>[] value) {</code>
<code> </code><code>this</code><code>.write(value,</code><code>0</code><code>, value ==</code><code>null</code>
<code>?</code><code>0</code>
<code>: value.length);</code>
<code>void</code> <code>write(</code><code>byte</code><code>[] d,</code><code>int</code>
<code>offset,</code><code>int</code>
<code> </code><code>if</code><code>(d ==</code><code>null</code>
<code>|| len ==</code><code>0</code><code>)</code><code>return</code><code>;</code>
<code>newCount = count + len;</code>
<code> </code><code>if</code><code>(newCount ></code><code>this</code><code>.data.length) {</code>
<code> </code><code>int</code>
<code>newSize = Math.max(</code><code>this</code><code>.data.length <<</code><code>1</code><code>, newCount);</code>
<code> </code><code>this</code><code>.data = BytesUtil.resizeBytes(</code><code>this</code><code>.data, newSize);</code>
<code> </code><code>System.arraycopy(d, offset,</code><code>this</code><code>.data,</code><code>this</code><code>.count, len);</code>
<code> </code><code>this</code><code>.count = newCount;</code>
<code>void</code> <code>writeInt(</code><code>int</code>
<code> </code><code>this</code><code>.write(BytesUtil.intToBytes(value));</code>
<code>void</code> <code>writeShort(</code><code>int</code>
<code> </code><code>this</code><code>.write(BytesUtil.shortToBytes(value));</code>
<code>void</code> <code>writeLong(</code><code>long</code>
<code> </code><code>this</code><code>.write(BytesUtil.longToBytes(value));</code>
<code>void</code> <code>writeByte(</code><code>byte</code>
<code>newCount = count +</code><code>1</code><code>;</code>
<code> </code><code>this</code><code>.data[count] = value;</code>
<code>void</code> <code>writeBytes(</code><code>byte</code><code>[] value) {</code>
<code>length = (value ==</code><code>null</code>
<code> </code><code>//发送大数据时</code>
<code> </code><code>if</code><code>(length >=</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>this</code><code>.writeShort(</code><code>0xFFFF</code><code>);</code>
<code> </code><code>this</code><code>.writeInt(length);</code>
<code> </code><code>}</code><code>else</code>
<code> </code><code>//告诉服务端发送的数据的大小</code>
<code> </code><code>this</code><code>.writeShort(length);</code>
<code> </code><code>this</code><code>.write(value);</code>
<code>void</code> <code>writeUTF(String value) {</code>
<code> </code><code>if</code><code>(value ==</code><code>null</code>
<code>|| value.length() ==</code><code>0</code><code>) {</code>
<code> </code><code>this</code><code>.writeShort(</code><code>0</code><code>);</code>
<code> </code><code>byte</code><code>[] bytes =</code><code>null</code><code>;</code>
<code> </code><code>try</code>
<code> </code><code>bytes = value.getBytes(</code><code>"UTF-8"</code><code>);</code>
<code> </code><code>}</code><code>catch</code>
<code> </code><code>e.printStackTrace();</code>
<code> </code><code>this</code><code>.writeBytes(bytes);</code>
TCPCommunication.java:上面的三个类都是辅助工具类,是给它使用的,它负责socket的创建和连接服务器、读取和发送数据,以及通过Handler发送消息给UI线程更新界面显示数据。由于我们的目的是使用socket通信,所以去掉了很多代码,这里只是简单的建立一次连接,发送和接收完数据后就关闭连接了。源码如下:
<code>class</code> <code>TCPCommunication</code><code>implements</code>
<code>Runnable {</code>
<code>Socket mSocket;</code>
<code>DataInputStream mDis;</code>
<code>DataOutputStream mDos;</code>
<code>Handler mHandler;</code>
<code>volatile</code> <code>boolean</code> <code>isRunning =</code><code>false</code><code>;</code>
<code>TCPCommunication(Handler handler) {</code>
<code> </code><code>this</code><code>.mHandler = handler;</code>
<code>boolean</code> <code>isRunning() {</code>
<code>isRunning;</code>
<code>void</code> <code>startWork() {</code>
<code> </code><code>Thread t =</code><code>new</code>
<code>Thread(</code><code>this</code><code>);</code>
<code> </code><code>t.setPriority(Thread.MAX_PRIORITY);</code>
<code> </code><code>t.start();</code>
<code>void</code> <code>stopWork() {</code>
<code> </code><code>this</code><code>.isRunning =</code><code>false</code><code>;</code>
<code> </code><code>@Override</code>
<code>void</code> <code>run() {</code>
<code> </code><code>mSocket =</code><code>new</code>
<code>Socket(</code><code>"10.0.2.2"</code><code>,</code><code>8888</code><code>);</code>
<code> </code><code>mDis =</code><code>new</code>
<code>DataInputStream(mSocket.getInputStream());</code>
<code> </code><code>mDos =</code><code>new</code>
<code>DataOutputStream(mSocket.getOutputStream());</code>
<code> </code><code>//开始发送数据到服务端</code>
<code> </code><code>BytesWriter bw =</code><code>new</code>
<code>BytesWriter();</code>
<code> </code><code>String username =</code><code>"alexzhou"</code><code>;</code>
<code> </code><code>String password =</code><code>"123456"</code><code>;</code>
<code>flag1 =</code><code>12345</code><code>;</code>
<code> </code><code>short</code>
<code>flag2 =</code><code>12</code><code>;</code>
<code> </code><code>long</code>
<code>flag3 = 100000000L;</code>
<code> </code><code>bw.writeUTF(username);</code>
<code> </code><code>bw.writeUTF(password);</code>
<code> </code><code>bw.writeInt(flag1);</code>
<code> </code><code>bw.writeShort(flag2);</code>
<code> </code><code>bw.writeLong(flag3);</code>
<code> </code><code>byte</code><code>[] data = bw.getBytes();</code>
<code> </code><code>BytesWriter out =</code><code>null</code><code>;</code>
<code> </code><code>if</code><code>(data.length >=</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>out =</code><code>new</code>
<code>BytesWriter(data.length +</code><code>6</code><code>);</code>
<code> </code><code>out.writeShort(</code><code>0xFFFF</code><code>);</code>
<code> </code><code>out.writeInt(data.length);</code>
<code> </code><code>}</code><code>else</code><code>{</code>
<code>BytesWriter(data.length +</code><code>2</code><code>);</code>
<code> </code><code>out.writeShort(data.length);</code>
<code> </code><code>out.write(data);</code>
<code> </code><code>mDos.write(out.getBytes());</code>
<code> </code><code>//开始从服务端接收数据</code>
<code>len = mDis.readShort();</code>
<code> </code><code>if</code><code>(len ==</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>len = mDis.readInt();</code>
<code> </code><code>byte</code><code>[] inputData =</code><code>new</code>
<code> </code><code>BytesUtil.readData(mDis, inputData,</code><code>0</code><code>, len);</code>
<code> </code><code>BytesReader br =</code><code>new</code>
<code>BytesReader(inputData);</code>
<code> </code><code>String user_id = br.readUTF();</code>
<code> </code><code>String recv_username = br.readUTF();</code>
<code> </code><code>String nickname = br.readUTF();</code>
<code>i = br.readInt();</code>
<code>s = br.readShort();</code>
<code>l = br.readLong();</code>
<code> </code><code>String result =</code><code>"登录成功~您的信息如下\n id:"</code><code>+user_id +</code><code>"\n用户名:"</code>
<code>+ recv_username +</code><code>"\n昵称:"</code>
<code>+ nickname +</code><code>"\n 序列号:"</code> <code>+ i +</code><code>"-"</code>
<code>+ s +</code><code>"-"</code>
<code>+ l;</code>
<code> </code><code>Message msg = mHandler.obtainMessage();</code>
<code> </code><code>msg.what =</code><code>0</code><code>;</code>
<code> </code><code>msg.obj = result;</code>
<code> </code><code>mHandler.sendMessage(msg);</code>
<code> </code><code>mDis.close();</code>
<code> </code><code>mDos.close();</code>
<code> </code><code>mSocket.close();</code>
<code>(UnknownHostException e) {</code>
<code> </code><code>};</code>
MainActivty.java的代码比较简单,源码:
<code>class</code> <code>MainActivity</code><code>extends</code>
<code>Activity {</code>
<code>TextView mTextView;</code>
<code>Button mButton;</code>
<code>void</code> <code>onCreate(Bundle savedInstanceState) {</code>
<code> </code><code>super</code><code>.onCreate(savedInstanceState);</code>
<code> </code><code>setContentView(R.layout.activity_main);</code>
<code> </code><code>mTextView = (TextView)</code><code>this</code><code>.findViewById(R.id.text);</code>
<code> </code><code>mButton = (Button)</code><code>this</code><code>.findViewById(R.id.button_send);</code>
<code> </code><code>mButton.setOnClickListener(</code><code>new</code>
<code>OnClickListener() {</code>
<code> </code><code>@Override</code>
<code> </code><code>public</code>
<code>void</code> <code>onClick(View v) {</code>
<code> </code><code>new</code>
<code>TCPCommunication(mHandler).startWork();</code>
<code> </code><code>});</code>
<code>Handler mHandler =</code><code>new</code>
<code>Handler() {</code>
<code> </code><code>@Override</code>
<code> </code><code>public</code>
<code>void</code> <code>handleMessage(Message msg) {</code>
<code> </code><code>String result = (String)msg.obj;</code>
<code> </code><code>mTextView.setText(result);</code>
<code>boolean</code> <code>onCreateOptionsMenu(Menu menu) {</code>
<code> </code><code>getMenuInflater().inflate(R.menu.activity_main, menu);</code>
<code>true</code><code>;</code>
到此为止,Android客户端的代码已经全部完成了,记得给应用添加访问网络的权限哦:在配置文件中添加
<code><</code><code>uses-permission</code>
<code>android:name</code><code>=</code><code>"android.permission.INTERNET"</code>
<code>/></code>
2.服务端代码实现
服务端的代码比较简单,当然了,一般在实际的开发中,服务端和客户端不是同一个人写的,这里我就把客户端里的那几个工具类拿来直接用了。
创建一个java项目,然后把BytesReader.java、BytesWriter.java、BytesUtil.java三个文件拷贝到项目的包下,然后创建Server.java,功能比较简单,监听8888端口,然后等待客户端连接,接收和发送数据。源码如下:
<code>final</code> <code>class</code> <code>Server</code><code>implements</code>
<code>Runnable{</code>
<code>ServerSocket mServerSocket;</code>
<code>Socket mClient;</code>
<code>boolean</code> <code>isRunning =</code><code>false</code><code>;</code>
<code>void</code> <code>start() {</code>
<code> </code><code>this</code><code>.isRunning =</code><code>true</code><code>;</code>
<code>void</code> <code>stop() {</code>
<code>static</code> <code>void</code> <code>main(String []args) {</code>
<code> </code><code>new</code>
<code>Server().start();</code>
<code> </code><code>mServerSocket =</code><code>new</code>
<code>ServerSocket(</code><code>8888</code><code>);</code>
<code> </code><code>System.out.println(</code><code>"start server"</code><code>);</code>
<code> </code><code>while</code><code>(isRunning) {</code>
<code> </code><code>System.out.println(</code><code>"wait client connect!!"</code><code>);</code>
<code> </code><code>mClient = mServerSocket.accept();</code>
<code> </code><code>//接收客户端发送的数据</code>
<code> </code><code>mDis =</code><code>new</code>
<code>DataInputStream(mClient.getInputStream());</code>
<code> </code><code>//数据的长度</code>
<code> </code><code>if</code><code>(len ==</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>len = mDis.readInt();</code>
<code> </code><code>}</code>
<code> </code><code>System.out.println(</code><code>"client data size:"</code> <code>+ len);</code>
<code> </code><code>byte</code><code>[] inputData =</code><code>new</code>
<code> </code><code>BytesUtil.readData(mDis, inputData,</code><code>0</code><code>, len);</code>
<code> </code><code>BytesReader br =</code><code>new</code>
<code> </code><code>String username = br.readUTF();</code>
<code> </code><code>String password = br.readUTF();</code>
<code> </code><code>short</code>
<code> </code><code>long</code>
<code> </code><code>System.out.println(</code><code>"username:"</code><code>+username+</code><code>";password="</code><code>+password+</code><code>"Long="</code><code>+l);</code>
<code> </code><code>//向客户端发送数据</code>
<code> </code><code>mDos =</code><code>new</code>
<code>DataOutputStream(mClient.getOutputStream());</code>
<code> </code><code>BytesWriter bw =</code><code>new</code>
<code>BytesWriter(</code><code>32</code><code>);</code>
<code> </code><code>String user_id =</code><code>"123456"</code><code>;</code>
<code> </code><code>String nickname =</code><code>"周江海"</code><code>;</code>
<code> </code><code>bw.writeUTF(user_id);</code>
<code> </code><code>bw.writeUTF(username);</code>
<code> </code><code>bw.writeUTF(nickname);</code>
<code> </code><code>bw.writeInt(i);</code>
<code> </code><code>bw.writeShort(s);</code>
<code> </code><code>bw.writeLong(l);</code>
<code> </code><code>byte</code><code>[] data = bw.getBytes();</code>
<code> </code><code>BytesWriter out =</code><code>null</code><code>;</code>
<code> </code><code>if</code><code>(data.length >=</code><code>0xFFFF</code><code>) {</code>
<code> </code><code>out =</code><code>new</code>
<code> </code><code>out.writeShort(</code><code>0xFFFF</code><code>);</code>
<code> </code><code>out.writeInt(data.length);</code>
<code> </code><code>}</code><code>else</code>
<code> </code><code>out.writeShort(data.length);</code>
<code> </code><code>out.write(data);</code>
<code> </code><code>mDos.write(out.getBytes());</code>
<code> </code><code>mDos.close();</code>
<code> </code><code>mDis.close();</code>
<code> </code><code>mClient.close();</code>
<code> </code><code>} </code>
现在验证一下,先启动Server,然后运行Android客户端应用,屏幕中间会出现TextView和一个button,TextView的内容是HelloWorld,点击button就会发送登陆信息给服务端,然后服务端返回数据显示到TextView上。下面分别是服务端的打印消息和客户端的显示截图。

主要需要掌握基本数据类型和字符串跟字节数组的转换,然后按照指定的顺序发送。最重要的是要注意客户端和服务端从字节数组读取和往字节数组写入数据时的顺序要对应。