天天看点

网游开发之socket的简单设计

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 &gt;&gt;&gt;</code><code>8</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>0</code><code>) &amp;</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 &gt;&gt;&gt;</code><code>24</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>16</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>2</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>8</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>3</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>0</code><code>) &amp;</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 &gt;&gt;&gt;</code><code>56</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>1</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>48</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>2</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>40</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>3</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>32</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>4</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>24</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>5</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>16</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>6</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>8</code><code>) &amp;</code><code>0xFF</code><code>);</code>

<code>        </code><code>write[</code><code>7</code><code>] = (</code><code>byte</code><code>)( (value &gt;&gt;&gt;</code><code>0</code><code>) &amp;</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>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>24</code><code>;</code>

<code>i2 = (value[</code><code>1</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>16</code><code>;</code>

<code>i3 = (value[</code><code>2</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>8</code><code>;</code>

<code>i4 = (value[</code><code>3</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</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>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>8</code><code>;</code>

<code>s2 = (value[</code><code>1</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</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>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>56</code><code>;</code>

<code>L2 = (value[</code><code>1</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>48</code><code>;</code>

<code>L3 = (value[</code><code>2</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>40</code><code>;</code>

<code>L4 = (value[</code><code>3</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>32</code><code>;</code>

<code>L5 = (value[</code><code>4</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>24</code><code>;</code>

<code>L6 = (value[</code><code>5</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>16</code><code>;</code>

<code>L7 = (value[</code><code>6</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</code><code>8</code><code>;</code>

<code>L8 = (value[</code><code>7</code><code>] &amp;</code><code>0xFF</code><code>) &lt;&lt;</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 &lt;</code><code>0</code>

<code>|| origin.length - from &lt;=</code><code>0</code><code>) {</code>

<code>            </code><code>throw</code>

<code>new</code> <code>IllegalArgumentException(</code><code>"copyBytes-&gt;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 &lt;</code><code>0</code><code>) {</code>

<code>new</code> <code>IllegalArgumentException(</code><code>"resizeBytes-&gt;newSize must &gt;= 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 &lt; 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 &gt; BUFFER ? BUFFER : remain);</code>

<code>                </code><code>if</code><code>(count &lt;</code><code>0</code><code>)</code><code>throw</code>

<code>new</code> <code>IOException(</code><code>"readData-&gt;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 &lt;</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 &gt;</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>&amp; 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 &gt;=</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 &gt;</code><code>this</code><code>.data.length) {</code>

<code>            </code><code>int</code>

<code>newSize = Math.max(</code><code>this</code><code>.data.length &lt;&lt;</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 &gt;=</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 &gt;=</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>&lt;</code><code>uses-permission</code>

<code>android:name</code><code>=</code><code>"android.permission.INTERNET"</code>

<code>/&gt;</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 &gt;=</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上。下面分别是服务端的打印消息和客户端的显示截图。

网游开发之socket的简单设计
网游开发之socket的简单设计
网游开发之socket的简单设计

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

继续阅读