摘要：
“）；｝catch（异常）｛updatetrack（”客户端：错误！“）；｛｝｝publicclassServer实现可运行的｛@Overridepublicvoidrun（）｛while（true）｛try｛InetAddressserverAddr=InetAddress。getByName（SERVERIP）；updatetrack（“服务器：开始连接”）；DatagramSocketsocket=newDatagram套接字（服务器端口，服务器地址）；byte[]buf=newbyte[17]；Datagram Packetpacket=newDatagramPacket（buf，buf.length）；updatetrack（服务器：接收）；socket.receive（数据包）；updatatrack（“服务器：消息接收：”“+newString（packet.getData（））+”“”“）；updatetrack（“服务器：成功！”）；}catch（异常）｛updatetrack（“服务器：错误！”）；｝｝｝｝publicvoidupdatetrack（字符串）｛Messagemsg=newMessage（）；StringtextTochange=s；msg.obj=textTochange；Handler.sendMessage（msg）；｝@覆盖publicbooleanCreateOptionsMenu（菜单菜单）｛//充气菜单；这将站点添加到显示的反应区。getMenuInflator（）。充气（R.menu.activity_main，菜单）；returntrue；｝@覆盖publicvoidonClick（Viewv）｛//TODOAuto-generatedmethodstudif（v.getId（）==R.id.button1）｛Tools.Queue_Send.offer（input.getText（）.toString（））；Log.d（“条目数”，Tools.Queee_Send.size（）+“”）；｝｝布局代码：˂？xmlversion=“1.0”encoding=“utf-8”？
主代码：
packagecom.example.test; importjava.net.DatagramPacket; importjava.net.DatagramSocket; importjava.net.InetAddress; importandroid.os.Bundle; importandroid.os.Message; importandroid.app.Activity; importandroid.util.Log; importandroid.view.Menu; importandroid.view.View; importandroid.widget.Button; importandroid.widget.EditText; importandroid.widget.TextView; importandroid.os.Handler; public class MainActivity extends Activity implementsandroid.view.View.OnClickListener { public static final String SERVERIP = "127.0.0.1"; public static final int SERVERPORT = 4444; publicTextView text1; publicEditText input; publicButton btn; publicHandler Handler; @Override protected voidonCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); text1 =(TextView) findViewById(R.id.textView1); input =(EditText) findViewById(R.id.editText1); btn =(Button) findViewById(R.id.button1); btn.setOnClickListener(this); Handler = newHandler() { @Override public voidhandleMessage(Message msg) { String text =(String) msg.obj; text1.append(text); } }; new Thread(newServer()).start(); new Thread(newClient()).start(); } public class Client implementsRunnable { privateDatagramPacket packet; privateDatagramSocket socket; publicClient() { } @Override public voidrun() { while(true) { if(Tools.Queue_Send.size()>0) { Log.d("Client个数", Tools.Queue_Send.size()+""); try{ InetAddress serverAddr =InetAddress.getByName(SERVERIP); updatetrack("Client: Start connecting "); socket = newDatagramSocket(); byte[] buf =Tools.Queue_Send.poll().toString().getBytes(); packet = newDatagramPacket(buf, buf.length, serverAddr, SERVERPORT); updatetrack("Client: Sending ‘" + new String(buf) + "’ "); socket.send(packet); socket.close(); updatetrack("Client: Message sent "); updatetrack("Client: Succeed! "); } catch(Exception e) { updatetrack("Client: Error! "); } } } } } public class Server implementsRunnable { @Override public voidrun() { while (true) { try{ InetAddress serverAddr =InetAddress.getByName(SERVERIP); updatetrack(" Server: Start connecting "); DatagramSocket socket = newDatagramSocket(SERVERPORT, serverAddr); byte[] buf = new byte[17]; DatagramPacket packet = newDatagramPacket(buf, buf.length); updatetrack("Server: Receiving "); socket.receive(packet); updatetrack("Server: Message received: ‘" + new String(packet.getData()) + "’ "); updatetrack("Server: Succeed! "); } catch(Exception e) { updatetrack("Server: Error! "); } } } } public voidupdatetrack(String s) { Message msg = newMessage(); String textTochange =s; msg.obj =textTochange; Handler.sendMessage(msg); } @Override public booleanonCreateOptionsMenu(Menu menu) { //Inflate the menu; this adds items to the action bar if it is present. getMenuInflater().inflate(R.menu.activity_main, menu); return true; } @Override public voidonClick(View v) { //TODO Auto-generated method stub if(v.getId()==R.id.button1) { Tools.Queue_Send.offer(input.getText().toString()); Log.d("加入个数", Tools.Queue_Send.size()+""); } } }
布局代码：
<?xml version= "1.0" encoding = "utf-8"?> <LinearLayout xmlns:android ="http://schemas.android.com/apk/res/android"android:layout_width= "fill_parent"android:layout_height ="fill_parent"android:orientation ="vertical" > <EditText android:id ="@+id/editText1"android:layout_width ="match_parent"android:layout_height ="wrap_content" > <requestFocus android:layout_width= "match_parent" /> </EditText> <Button android:id ="@+id/button1"android:layout_width ="wrap_content"android:layout_height ="wrap_content"android:text = "Send" /> <ScrollView android:layout_width= "wrap_content"android:layout_height= "wrap_content" > <TextView android:id= "@+id/textView1"android:layout_width= "wrap_content"android:layout_height= "wrap_content"android:scrollbars= "vertical"android:text= "Communication History:"android:textAppearance= "?android:attr/textAppearanceLarge" /> </ScrollView> </LinearLayout>
Tools类：
packagecom.example.test; importjava.util.ArrayList; importjava.util.LinkedList; importjava.util.Queue; public classTools { /*** 发送队列 * */ public static Queue<String> Queue_Send = new LinkedList<String>(); }
可以实现发送接收。
在这之前，我一直想实现点击发送就可以收到。
我知道服务器端和客户端都是线程一直开着，问题是客户端线程已经开着我怎样才能把要发的数据加载进去。
开始我想着用Handle类，这样应该可以实现，但做了一下，有点麻烦。
后面就建了一个静态数据队列，保存要发送的数据，这样就很简单了。
自己菜可以原谅，如果不学习就不可原谅。