java服务端和用户端

1.server

Logintherad:

package com.zdsofe.server;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Set;

/**
 * 主要用于用户登录
 * 
 * @author Administrator
 *
 */
public class Logintherad extends Thread
{
    Socket client;
    int n;// n的值表示用户是否连接上

    public Logintherad(Socket client)
    {
        this.client = client;
    }

    @Override
    public void run()
    {
        try
        {
            // 调用登录处理的方法
            loginServer();
            // 判断是否登录成功
            if (n == 1)
            {
                // 开启发送信息的线程
                new SendThread(client).start();
            }
        } catch (Exception e)
        {

            e.printStackTrace();
        }
    }

    // 登录处理方法
    private void loginServer() throws Exception
    {
        // 获取输入流
        InputStream inputStream = client.getInputStream();
        // 获取输出流
        OutputStream outputStream = client.getOutputStream();
        // 创建数组用来存放读取的昵称
        byte[] bytes = new byte[1024];
        // 从流里读取客服的昵称，放入数组中
        inputStream.read(bytes);
        // 把数组转化为String类型
        String nickName = new String(bytes);
        // 保存昵称到Set集合
        boolean b = UserInfo.nickNames.add(nickName);
        // 判断登录的状态
        if (b)
        {
            n = 1;
            // 登录成功
            outputStream.write("1".getBytes());
            // 登录成功后把用户信息存放在hashMap集合中
            UserInfo.hashMap.put(client, nickName);
            // 获取hashMap集合的键，也就是获取用户
            Set<Socket> set = UserInfo.hashMap.keySet();
            // 遍历set集合，发送登录成功的信息给其他客户，
            for (Socket socket : set)
            {
                if (client != socket)// 排除把登录成功的信息发送给自己
                {
                    OutputStream os = socket.getOutputStream();
                    // 输出客户上线
                    os.write((nickName + "上线了").getBytes());
                }
            }

        } else
        {
            n = 0;
            // 登录失败，输出0
            outputStream.write("0".getBytes());
        }
    }

}

SendThread:

package com.zdsofe.server;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.util.Set;

/**
 * 发送信息的线程
 * 
 * @author Administrator
 *
 */
public class SendThread extends Thread
{
    Socket socket;
    public SendThread(Socket socket)
    {
        this.socket = socket;
    }

    @Override
    public void run()
    {
        while (true)
        {
            try
            {
                // 创建输入流
                InputStream inputStream = socket.getInputStream();
                // 创建数组
                byte[] bytes = new byte[1024];
                // 把信息存入字节数组里
                inputStream.read(bytes);
                // 把数组转化为String类型
                String s = new String(bytes);
                // 获取所有客户端的列表
                Set<Socket> set = UserInfo.hashMap.keySet();
                // 遍历set集合，得到所有用户
                for (Socket socket : set)
                {
                    // 使用户得到输出的信息
                    socket.getOutputStream().write(s.getBytes());
                }
            } catch (IOException e)
            {
                e.printStackTrace();
            }

        }
    }

}

TestServer:

package com.zdsofe.server;

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

public class TestServer
{

    public static void main(String[] args)
    {
        try
        {
            // 创建服务器
            ServerSocket serverSocket = new ServerSocket(8000);
            while (true)
            {
                // 等待客服连接
                Socket socket = serverSocket.accept();
                // 调用线程(登录和发消息的线程)
                new Logintherad(socket).start();
            }
        } catch (IOException e)
        {
            e.printStackTrace();
        }

    }

}

UserInfo:

package com.zdsofe.server;

import java.net.Socket;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Set;

/**
 * 保存用户信息
 * 
 * @author Administrator
 *
 */
public class UserInfo
{
    // 连接信息存在hashMap集合里
    public static HashMap<Socket, String> hashMap = new HashMap<Socket, String>();
    // 把用户的昵称信息存入set集合
    public static Set<String> nickNames = new HashSet<String>();

}

2.socket

ReceiveThread:

package com.zdsofe.socket;

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

public class ReceiveThread extends Thread
{
 private  Socket socket;

public ReceiveThread(Socket socket)
{
    
    this.socket = socket;
}

@Override
public void run()
{
    while(true)
    {    
    try
    {
        //创建输入流
        InputStream inputStream=socket.getInputStream();
        //创建字节数组
        byte[]bytes=new byte[1024];
        //把读的数据放在数组里
        inputStream.read(bytes);
        //转化为字符串类型并打印
        System.out.println(new String(bytes));
        
    } catch (IOException e)
    {
        
        e.printStackTrace();
    }
    }
}
 
}

SendThread:

package com.zdsofe.socket;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class SendThread extends Thread
{
 private Socket socket;

public SendThread(Socket socket)
{    
    this.socket = socket;
}

@Override
public void run()
{
    //开启键盘扫描
    Scanner sc=new Scanner(System.in);
    while(true)
    {
        String s=sc.nextLine().trim();
        try
        {    
            //创建输出流
            OutputStream outputStream=socket.getOutputStream();
            //把字符串转化为字节，并写入
            outputStream.write(s.getBytes());
            
        } catch (IOException e)
        {
            
            e.printStackTrace();
        }
    }
}
}

TestUers:

package com.zdsofe.socket;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class TestUers
{
    // 服务器的IP地址
    private static String IP = "192.168.10.183";
    // 服务器的端口
    private static int DUAN = 8000;

    public static void main(String[] args) throws Exception
    {
        try
        {
            //创建Socket连接
            Socket socket = new Socket(IP, DUAN);            
            System.out.println("请输入昵称进行验证");
            //开启键盘扫描
            Scanner sc = new Scanner(System.in);
            String nickName = sc.nextLine().trim();
            //判断昵称是否为空
            if (nickName.equals(""))
            {
                System.out.println("昵称不能为空");
                return;
            }
            // 开始登陆
            loginServer(socket, nickName);
            // 开启发送的线程
            new SendThread(socket).start();
            // 开启接受的线程
            new ReceiveThread(socket).start();
        } catch (IOException e)
        {
            e.printStackTrace();
        }

    }

    // 登录的方法
    public static void loginServer(Socket socket, String nickName)
            throws Exception
    {
        // 获取输出流
        OutputStream outputStream = socket.getOutputStream();
        //把昵称写入
        outputStream.write(nickName.getBytes());
        // 获取输入流
        InputStream inputStream = socket.getInputStream();
        //创建字节数组
        byte[] bytes = new byte[1024];
        //把读取的信息存入数组里
        inputStream.read(bytes);
        //把数组转化为字符串类型
        String s = new String(bytes).trim();
        //判断登录是否成功
        if (s.equals("1"))
        {
            System.out.println("登录成功");
        } else if (s.equals("0"))
        {
            System.out.println("昵称重复");
        } else
        {
            System.out.println("服务器异常");
        }

    }
}