欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java网络编程TCP实现聊天功能

程序员文章站 2022-03-08 18:52:33
网络编程tcp实现聊天的前提还需要掌握io流,话不多说,直接上代码!客户端:package com.kuang.lesson02;import java.io.ioexception;import j...

网络编程tcp实现聊天的前提还需要掌握io流,话不多说,直接上代码!

客户端:

package com.kuang.lesson02;

import java.io.ioexception;
import java.io.outputstream;
import java.net.inetaddress;
import java.net.socket;

//客户端
public class tcpclientdemo01 {
    public static void main(string[] args) {
        socket socket = null;
        outputstream os = null;

        try {
            //1、要知道服务器的地址、端口号
            inetaddress serverip = inetaddress.getbyname("127.0.0.1");
            int port = 9999;

            //2、创建一个socket连接
            socket = new socket(serverip, port);

            //3、发送消息io流
            os = socket.getoutputstream();
            os.write("你好,java".getbytes());
        } catch (exception e) {
            e.printstacktrace();
        } finally {
            if (os != null) {
                try {
                    os.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
            if (socket != null) {
                try {
                    socket.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
        }
    }
}

服务端:

package com.kuang.lesson02;


import java.io.bytearrayoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.net.serversocket;
import java.net.socket;

//服务端
public class tcpserverdemo01 {
    public static void main(string[] args) {
        serversocket serversocket = null;
        socket socket = null;
        inputstream is = null;
        bytearrayoutputstream baos = null;

        try {
            //1、我得有一个地址
            serversocket = new serversocket(9999);

            while (true) {
                //2、等待客户端连接过来
                socket = serversocket.accept();

                //3、读取客户端的消息
                is = socket.getinputstream();

                //管道流
                baos = new bytearrayoutputstream();
                byte[] buffer = new byte[1024];
                int len;
                while ((len = is.read(buffer)) != -1) {
                    baos.write(buffer, 0, len);
                }
                system.out.println(baos.tostring());
            }


        } catch (exception e) {
            e.printstacktrace();
        } finally {
            //关闭资源
            if (baos != null) {
                try {
                    baos.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
            if (is != null) {
                try {
                    is.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
            if (socket != null) {
                try {
                    socket.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
            if (serversocket != null) {
                try {
                    serversocket.close();
                } catch (ioexception e) {
                    e.printstacktrace();
                }
            }
        }

    }
}

运行结果:

1、首先运行服务端,等待接收消息,可以发现服务端一直在运行

Java网络编程TCP实现聊天功能

2、接着运行客户端,发送消息,可以发现客户端运行结束

Java网络编程TCP实现聊天功能

3、返回服务端查看,可以发现服务端已经接收到了客户端发送来的消息

Java网络编程TCP实现聊天功能

4、由于是循环操作,所以只要客户端发送消息来,服务端就能接收到,可以实现多次发送消息。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

相关标签: java TCP 聊天