26
2017
09

Android的Socket通信Demo

某个人一直在问我Socket通信的问题,太久没有用了,差不多都忘了啊000。
具体什么事Socket,搜索一下就能看到了,我表达能力不行,别误导了。。代码中的输入输出流如果不懂的话,嗯,也搜索一下,流这部分的知识有些多哦。
找了一下,基于TCP实现Socket通信,下面是代码(JAVA):
一:服务端接受客户端的消息
客户端LoginClient.java

package com.bjsxt.socket.tcp.login1;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/** * 登录客户端 */
public class LoginClient {

    public static void main(String[] args) throws UnknownHostException, IOException {
        //1.创建Socket,用来发送请求
        Socket  socket = new Socket(InetAddress.getByName("127.0.0.1"), 8888);

        //2.创建输出流
        OutputStream os = socket.getOutputStream();
        DataOutputStream dos = new DataOutputStream(os);

        //3.发送数据
        String info = "username=bjsxt&password=bjsxt";
        dos.writeUTF(info);

        //4.关闭流和socket
        dos.close();
        os.close();
        socket.close();

    }

}

服务端 LoginServer.java

package com.bjsxt.socket.tcp.login1;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/** * 登录服务器端 */
public class LoginServer {

    public static void main(String[] args) throws IOException {
        //1.创建一个ServerSocket,指定等待端口
        ServerSocket serverSocket = new ServerSocket(8888);

        //2.使用ServerSocket接收用户的请求(处于监听状态)
        Socket socket = serverSocket.accept();

        //3.创建输入流来接收用户的数据
        InputStream is = socket.getInputStream();
        DataInputStream dis = new DataInputStream(is);

        //4.接收用户数据并输出
        String result = dis.readUTF();
        System.out.println("我是服务器,收到的信息是:"+result);

        //5.关闭流和socket
        dis.close();
        is.close();
        socket.close();
        serverSocket.close();

    }

}

二:服务端接收客户端消息后,发送消息给客户端接收
客户端代码:LoginClient.java

package com.bjsxt.socket.tcp.login3;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/** * 登录客户端 */
public class LoginClient {

    public static void main(String[] args) {

        Socket socket = null;;
        DataInputStream dis =null;
        DataOutputStream dos =null;
        try {
            //1.创建Socket,用来发送请求
            socket = new Socket(InetAddress.getByName("127.0.0.1"), 8888);
            //2.创建输入流和输出流 
            dis = new DataInputStream(socket.getInputStream());
            dos = new DataOutputStream(socket.getOutputStream());

            //3.发送数据
            String info = "username=bjsxt&password=bjsxt";
            dos.writeUTF(info);

            //5.接收反馈信息并输出
            String answer = dis.readUTF();
            System.out.println("我是客户端,服务端的反馈信息是:"+answer);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            //4.关闭流和socket
            try {
                dis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                dos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }   
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }





    }

}

服务端代码:LoginServe.java

package com.bjsxt.socket.tcp.login3;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/** * 登录服务器端 * 理解TCP编程的步骤 * 1.服务器创建ServerSocket,在指定端口监听并并处理请求;客户端创建Socket,向服务器发送请求 * 2.ServletSocket通过accept() 接收用户请求并返回对应的Socket,否则一种处于监听等待状态,线程也被阻塞 * 3.客户端发送请求数据使用输出流,客户端接收反馈信息使用输入流 * 4.服务器端接收请求数据使用输入流,服务器端发送反馈信息使用输出流 * 5.一旦使用ServerSocket和Socket建立了网络连接后,网络通信和普通IO流操作并没有太大区别 * 6.网络通信输出流建议使用DataOutputStream和ObjectOutputStream,与平台无关,输入流相应使用DataIntputStream和ObjectInputStream * 7.如果是字符串通信也可以使用BufferedReader(readLine())和PrintWriter(println()),简单方便 * 添加异常处理代码 */
public class LoginServer {

    public static void main(String[] args) {

        ServerSocket serverSocket = null;
        Socket socket = null;
        DataInputStream dis =null;
        DataOutputStream dos =null;
        try {
            //1.创建一个ServerSocket,指定等待端口
            serverSocket = new ServerSocket(8888);
            //2.使用ServerSocket接收用户的请求(处于监听状态)
            socket = serverSocket.accept();

            //3.创建输入流和输出流 
            dis = new DataInputStream(socket.getInputStream());
            dos = new DataOutputStream(socket.getOutputStream());

            //4.接收用户数据并输出
            String result = dis.readUTF();
            System.out.println("我是服务器,收到的信息是:"+result);

            //5.发送反馈信息
            String answer ="欢迎您";
            dos.writeUTF(answer);   

        } catch (IOException e) {           
            e.printStackTrace();
        }finally{
            //6.关闭流和socket
            try {
                dis.close();                
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {               
                dos.close();                
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                socket.close();             
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}
上一篇:Spring定时器Quartz,定时调用存储过程 下一篇:谷歌和火狐浏览器下的input的padding不同表现