//TCP向服务端发送数据public void TCP_sendMsg(String msg) {Socket socket = null;OutputStream output = null;InputStream input = null;try {// socket = new Socket(InetAddress.getByName("192.168.1.100"), 8888);//这种形式也行socket = new Socket("192.168.1.100", 8888);// 第一个参数是目标主机名或目标主机的ip地址，第二个参数是目标主机端口号output = socket.getOutputStream();output.write(msg.getBytes());// 把msg信息写入输出流中//--------接收服务端的返回信息-------------socket.shutdownOutput(); // 一定要加上这句，否则收不到来自服务器端的消息返回 ，意思就是结束msg信息的写入input = socket.getInputStream();byte[] b = new byte[1024];int len = -1;sb = new StringBuffer();while ((len = input.read(b)) != -1) {sb.append(new String(b, 0, len, Charset.forName("gbk")));// 得到返回信息}// 在主线程中更新UIrunOnUiThread(new Runnable() {@Overridepublic void run() {mTextView.setText(sb.toString());// 将返回信息设置到界面显示}});} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {try {// 注意，输出流不需要关闭，因为它只是在Socket中得到输出流对象，并没有创建if (socket != null) {socket.close();// 释放资源，关闭这个Socket}} catch (IOException e) {e.printStackTrace();}}}

public void ReceiveMsg() {ServerSocket server = null;Socket socket = null;try {server = new ServerSocket(8888);// 创建一个ServerSocket对象，并让这个Socket在8080端口监听// 调用ServerSocket的accept()方法，接受客户端所发送的请求，同时创建一个Socket对象// 如果客户端没有发送数据，那么该线程就停滞不继续,也就是阻塞while(true){socket = server.accept();System.out.println(socket.getInetAddress().getHostName());System.out.println(socket.getInetAddress().getHostAddress());//得到当前发送数据Socket对象的主机名和ip地址InputStream input = socket.getInputStream();// 得到该Socket对象的输入流BufferedInputStream bis = new BufferedInputStream(input);byte[] b = new byte[1024];int len = -1;while ((len = bis.read(b)) != -1) {// 从InputStream当中读取客户端所发送的数据System.out.println(new String(b, 0, len,"UTF-8"));}//--------向客户端的返回信息-------------socket.shutdownInput();//结束读取OutputStream outputResult = socket.getOutputStream();//不需要关闭outputResult.write("ok,我已经收到！".getBytes());bis.close();//关闭缓存输入流，注意，输入流input不需要关闭，因为它只是在Socket中得到输入流对象，并没有创建socket.close();//接收这个Socket的数据后释放资源，因为每一次客户端发送数据都会在服务端创建一个Socket对象，注意ServerSocket不应该关闭，因为这是服务器ServerSocket对象，关闭了客户端就不能发送数据了socket = null;}		} catch (IOException e) {e.printStackTrace();}}

//发送数据包给服务端和接收返回的数据public void UDP_send(String msg) {DatagramSocket socket = null;try {socket = new DatagramSocket(8880);// 创建DatagramSocket对象并绑定一个本地端口号，注意，如果客户端需要接收服务器的返回数据,还需要使用这个端口号来接收数据，所以一定要记住byte[] data = msg.getBytes();// 把字符串转为字节数组// Inet4Address inetAddress = (Inet4Address)Inet4Address.getByName("192.168.1.100");//使用这个也行，表示使用4个字节的ip地址InetAddress inetAddress = InetAddress.getByName("192.168.1.100");// 得到ip或主机名为192.168.1.100的网络地址对象DatagramPacket pack = new DatagramPacket(data, data.length,inetAddress, 8881);// 参数分别为：发送数据的字节数组对象、数据的长度、目标主机的网络地址、目标主机端口号，发送数据时一定要指定接收方的网络地址和端口号socket.send(pack);//发送数据包//-----------接收服务器返回的数据-------------byte[] b = new byte[4*1024];//创建一个byte类型的数组，用于存放接收到得数据DatagramPacket pack2 = new DatagramPacket(b, b.length);// 定义一个DatagramPacket对象用来存储接收的数据包，并指定大小和长度socket.receive(pack2);//接收数据包// data.getData()是得到接收到的数据的字节数组对象，0为起始位置，pack.getLength()得到数据的长度final String result = new String(pack2.getData(),0,pack2.getLength(), "gbk");//把返回的数据转换为字符串socket.close();//释放资源//在线程中更新UIrunOnUiThread(new Runnable() {@Overridepublic void run() {mTextView1.setText(result);}});} catch (SocketException e) {e.printStackTrace();} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}

public void ReceiveMsg(){DatagramSocket socket = null;try {socket = new DatagramSocket(8881);// 创建DatagramSocket对象并绑定一个本地端口号while(true){byte[] buf = new byte[4*1024];//创建一个byte类型的数组，用于存放接收到得数据DatagramPacket pack = new DatagramPacket(buf, buf.length);//创建一个DatagramPacket对象，并指定DatagramPacket对象的大小和长度socket.receive(pack);//读取接收到得数据 包,如果客户端没有发送数据包，那么该线程就停滞不继续，这个同样也是阻塞式的String str = new String(pack.getData(), 0,pack.getLength(),"UTF-8");//将接收到的数据包转为字符串输出显示String ip = pack.getAddress().getHostAddress();//得到发送数据包的主机的ip地址System.out.println(ip+"发送:"+str);//-----------返回数据给客户端------------InetAddress address = pack.getAddress();//得到发送数据包主机的网络地址对象byte[] data = "已收到！".getBytes();DatagramPacket p = new DatagramPacket(data, data.length, address, 8880);socket.send(p);}//注意不需要关闭服务器的socket，因为它一直等待接收数据} catch (SocketException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}