Java 网络编程之 TCP 实现简单的聊天系统
客户端
1、连接服务器 Socket
2、发送消息
package lesson02;import java.io.IOException;import java.io.OutputStream;import java.net.InetAddress;import java.net.Socket;/** * 客户端 */public class TcpClientDemo1 { 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();} } } }}
服务端
1、建立服务的端口 ServerSocket
2、等待用户的连接 accept
3、接收用户的消息
package lesson02;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;/** * 服务端 */public class TcpServerDemo1 { 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()); } /* byte[] buffer = new byte[1024]; int len; while ((len = is.read(buffer)) != -1){String msg = new String(buffer, 0, len);System.out.println(msg); } */ } catch (IOException 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、建立服务的端口 ServerSocket
2、等待用户的连接 accept
3、接收用户的消息
package lesson02;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.InputStream;import java.net.ServerSocket;import java.net.Socket;/** * 服务端 */public class TcpServerDemo1 { 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()); } /* byte[] buffer = new byte[1024]; int len; while ((len = is.read(buffer)) != -1){String msg = new String(buffer, 0, len);System.out.println(msg); } */ } catch (IOException 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();} } } }}
以上就是Java 网络编程之 TCP 实现简单的聊天系统的详细内容,更多关于Java 实现简单的聊天系统的资料请关注好吧啦网其它相关文章!
相关文章:
1. Admin - SpringBoot + Maven 多启动环境配置实例详解2. Android WebView通过动态的修改js去拦截post请求参数实例3. SpringBoot2整合Ehcache组件实现轻量级缓存管理4. spring boot集成mongodb的增删改查的示例代码5. Django def clean()函数对表单中的数据进行验证操作6. 如何用python写个模板引擎7. django中嵌套的try-except实例8. 浅谈vue实现双向事件绑定v-model的原理9. Android自定义View实现气泡动画10. Django结合使用Scrapy爬取数据入库的方法示例