Android开发 java Socket应用 通信 实现多用户登录

释放双眼,带上耳机,听听看~!

Java Socket应用通信实现多用和登录,查询IP地址

服务端:

package JavaLearn;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * Created by ChenHe on 2017/2/20.
 *基于TCp协议socket通信,实现用户登录
*/
public class Server {
public static void main(String[] args){
try {
//1.创建一个服务端Socket,即ServerSocke,指定绑定端口,并监听此端口
ServerSocket serverSocket = new ServerSocket(8888);
//2.调用accept()方法开始监听,等待客户端的连接
System.out.println("******服务器即将启动,等待客户端的连接******");
Socket socket = null;
//记录客户端数量
int count = 0;
            while (true){
//调用accept()方法开始监听,等待客户端的连接
socket =  serverSocket.accept();
//创建一个新线程
ServerThread serverThread = new ServerThread(socket);
//启动线程
serverThread.start();
count ++;//统计客户端的数量
System.out.println("客户端数量:"+count);
//获取当前客户端的IP地址
InetAddress address = socket.getInetAddress();
System.out.println("当前客户端的IP地址:"+address.getHostAddress());
}
//            //3.获取输入流,并独缺客户端信息
//            InputStream is = socket.getInputStream();//字节输入流
//            InputStreamReader isr = new InputStreamReader(is);//将字节流转换为字符流
//            BufferedReader br = new BufferedReader(isr);//为字符流添加缓冲
//            String info = null;
//            while ((info = br.readLine())!=null){//循环读取客户端的信息
//                System.out.println("我是服务器,客户端说:"+info);
//            }
//            socket.shutdownInput();//关闭输入流
//
//            //4.获取输出流,响应端的请求
//            OutputStream os = socket.getOutputStream();
//            PrintWriter pw = new PrintWriter(os);
//            pw.write("欢迎您!admin");
//            pw.flush();
//
//            //关闭资源
//            pw.close();
//            os.close();
//            br.close();
//            isr.close();
//            is.close();
//            socket.close();
//            serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}

 

线程类:

package JavaLearn;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
/**
 * Created by ChenHe on 2017/2/21.
 * 服务器线程处理类
*/
public class ServerThread extends Thread{
//和本线程相关的Socket
Socket socket = null;
    public ServerThread(Socket socket){
this.socket = socket;
}
//线程执行操作,响应客户端请求
public void run(){
InputStream is = null;//字节输入流
InputStreamReader isr = null;//将字节流转换为字符流
BufferedReader br = null;//为字符流添加缓冲
OutputStream os = null;
PrintWriter pw = null;
        try {
//3.获取输入流,并独缺客户端信息
is = socket.getInputStream();
isr = new InputStreamReader(is);
br = new BufferedReader(isr);
String info = null;
            while ((info = br.readLine())!=null){//循环读取客户端的信息
System.out.println("我是服务器,客户端说:"+info);
}
socket.shutdownInput();//关闭输入流
//4.获取输出流,响应端的请求
os = socket.getOutputStream();
pw = new PrintWriter(os);
pw.write("欢迎您!admin");
pw.flush();
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
//关闭资源
if(pw!=null)
pw.close();
                if(os!=null)
os.close();
                if(br!=null)
br.close();
                if(isr!=null)
isr.close();
                if(is!=null)
is.close();
                if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

 

 

客户端:

package JavaLearn;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
/**
 * Created by ChenHe on 2017/2/20.
 * 客户端
*/
public class Client {
public static void main(String[] args){
try {
//1.创建客户端Socket,指定服务器地址和端口
Socket socket = new Socket("localhost",8888);
//2.获取输出流,向服务器端发送信息
OutputStream os = socket.getOutputStream();//字节输出流
PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流
pw.write("用户名:admin;密码:1236");
pw.flush();//刷新缓存,像服务端提交信息
socket.shutdownOutput();//关闭输出流
//3.获取输入流,并读取服务器端的响应信息
InputStream is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String info = null;
            while ((info = br.readLine())!=null){
System.out.println("我是客户端,服务器说:"+info);
}
//4.关闭资源
br.close();
is.close();
pw.close();
os.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}

 

 

人已赞赏
Android文章

android 毫秒转日期

2020-3-24 17:11:18

Android文章

Android Studio当中的编码问题

2020-3-24 17:36:28

个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
有新消息 消息中心
搜索