计算机网络技术与JAVA网络编程手写Socket聊天室-----JAVA入门基础教程-----计算机网络经典-Toy模板网

这篇具有很好参考价值的文章主要介绍了计算机网络技术与JAVA网络编程手写Socket聊天室-----JAVA入门基础教程-----计算机网络经典。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

import java.io.*;
import java.net.Socket;
import java.util.Scanner;

public class ChatClient
{
    public static void main(String[] args)
    {
        try
        {
            Socket socket = new Socket("127.0.0.1",9090);
            new Thread(new Runnable()
            {
                @Override
                public void run()
                {
                    InputStream inputStream = null;
                    while(true)
                    {
                        try
                        {
                            inputStream = socket.getInputStream();
                        }
                        catch (IOException e)
                        {
                            throw new RuntimeException(e);
                        }
                        Scanner out = new Scanner(inputStream);
                        while(out.hasNextLine())
                        {
                            System.out.println(out.nextLine());
                        }
                    }
                }
            }).start();
            new Thread(new Runnable()
            {
                @Override
                public void run()
                {
                    while(true)
                    {
                        Scanner in = new Scanner(System.in);
                        String string = in.nextLine();
                        try
                        {
                            OutputStream outputStream = socket.getOutputStream();
                            outputStream.write(string.getBytes(),0,string.length());
                        }
                        catch (IOException e)
                        {
                            throw new RuntimeException(e);
                        }
                        if("bye".equals(string))
                        {
                            break;
                        }
                    }
                }
            }).start();
        }
        catch (IOException e)
        {
            throw new RuntimeException(e);
        }
    }
}
import java.io.*;
import java.net.Socket;
import java.util.Scanner;

public class ChatClient
{
public static void main(String[] args)
{
try
{
Socket socket = new Socket("127.0.0.1",9090);
new Thread(new Runnable()
{
@Override
public void run()
{
InputStream inputStream = null;
while(true)
{
try
{
inputStream = socket.getInputStream();
}
catch (IOException e)
{
throw new RuntimeException(e);
}
Scanner out = new Scanner(inputStream);
while(out.hasNextLine())
{
System.out.println(out.nextLine());
}
}
}
}).start();
new Thread(new Runnable()
{
@Override
public void run()
{
while(true)
{
Scanner in = new Scanner(System.in);
String string = in.nextLine();
try
{
OutputStream outputStream = socket.getOutputStream();
outputStream.write(string.getBytes(),0,string.length());
}
catch (IOException e)
{
throw new RuntimeException(e);
}
if("bye".equals(string))
{
break;
}
}
}
}).start();
}
catch (IOException e)
{
throw new RuntimeException(e);
}
}
}

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class ChatServer
{
    public static void main(String[] args)
    {
        ArrayList<Socket> arrayList = new ArrayList<Socket>();
        new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                while(true)
                {
                    try
                    {
                        arrayList.add(new ServerSocket(9090).accept());
                    }
                    catch (IOException e)
                    {
                        throw new RuntimeException(e);
                    }
                }
            }
        }).start();
        new Thread(new Runnable()
        {
            @Override
            public void run()
            {
                while(true)
                {
                    if(arrayList.size() != 0)
                    {
                        for(int i = 0; i < arrayList.size(); i++)
                        {
                            String ip = arrayList.get(i).getInetAddress().getHostAddress();
                            try
                            {
                                int len;
                                byte[] bytes = new byte[10240];
                                while((len = arrayList.get(i).getInputStream().read()) != -1)
                                {
                                    arrayList.get(i).getOutputStream().write(bytes,0,len);
                                }
                            }
                            catch (IOException e)
                            {
                                throw new RuntimeException(e);
                            }
                            System.out.println(ip);
                        }
                    }
                    if(arrayList.size() == 0)
                    {
                        System.out.println("No User");
                    }
                }
            }
        }).start();
    }
}
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class ChatServer
{
public static void main(String[] args)
{
ArrayList<Socket> arrayList = new ArrayList<Socket>();
new Thread(new Runnable()
{
@Override
public void run()
{
while(true)
{
try
{
arrayList.add(new ServerSocket(9090).accept());
}
catch (IOException e)
{
throw new RuntimeException(e);
}
}
}
}).start();
new Thread(new Runnable()
{
@Override
public void run()
{
while(true)
{
if(arrayList.size() != 0)
{
for(int i = 0; i < arrayList.size(); i++)
{
String ip = arrayList.get(i).getInetAddress().getHostAddress();
try
{
int len;
byte[] bytes = new byte[10240];
while((len = arrayList.get(i).getInputStream().read()) != -1)
{
arrayList.get(i).getOutputStream().write(bytes,0,len);
}
}
catch (IOException e)
{
throw new RuntimeException(e);
}
System.out.println(ip);
}
}
if(arrayList.size() == 0)
{
System.out.println("No User");
}
}
}
}).start();
}
}文章来源地址https://www.toymoban.com/news/detail-606325.html