基于Java_Socket通信程序设计

⼀个简单的Socket通信Demo服务器端Demo:Server.java(服务器端运⾏主程序，直接运⾏):package cn.wjs;import .InetAddress;import .ServerSocket;import .Socket;public class Server {private static final int port = 9999;private static final int backlog = 100;private static final String bindAddr = "127.0.0.1";public static void main(String[] args) throws Exception {System.out.println("正在启动Socket服务器");ServerSocket server = new ServerSocket(9998, 100, InetAddress.getByName("127.0.0.1"));System.out.println("启动完成\n正在监听客户端连接");while (true) {Socket socket = server.accept();System.out.println("产⽣了⼀个新的会话,来⾃:" + socket.getInetAddress() + "\n=================================="); new ServerMessageReceiver(socket).start();new ServerMessageSender(socket).start();System.out.println("服务器端已启动");}}}ServerMessageReceiver.java:package cn.wjs;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.UnsupportedEncodingException;import .Socket;public class ServerMessageReceiver extends Thread{private Socket socket;public ServerMessageReceiver(Socket socket){this.socket = socket;}public void run() {try {BufferedReader reader = new BufferedReader(new InputStreamReader(this.socket.getInputStream(), "UTF-8"));String content = null;while (true) {if (this.socket.isClosed()) {System.out.println("Socket已经关闭");reader.close();this.socket.close();break;}content = reader.readLine();if (content.equals("bye")) {System.out.println("对⽅请求关闭连接,⽆法继续进⾏聊天");reader.close();this.socket.close();break;}System.out.println("【对⽅】" + content + "\n");}reader.close();this.socket.close();}catch (UnsupportedEncodingException e){e.printStackTrace();}catch (IOException e) {e.printStackTrace();}}}ServerMessageSender.java:package cn.wjs;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.io.UnsupportedEncodingException;import .Socket;public class ServerMessageSender extends Thread{private Socket socket;public ServerMessageSender(Socket socket){this.socket = socket;}public void run() {try {BufferedWriter outwriter = new BufferedWriter(new OutputStreamWriter(this.socket.getOutputStream(), "UTF-8")); BufferedReader inputReader = new BufferedReader(new InputStreamReader(System.in));String msg = null;while (true) {msg = inputReader.readLine();if (msg.toLowerCase().equals("exit")) {System.exit(0);}if (this.socket.isClosed()) {System.out.println("Socket已经关闭");outwriter.close();inputReader.close();this.socket.close();break;}outwriter.write(msg);outwriter.newLine();outwriter.flush();}}catch (UnsupportedEncodingException e){e.printStackTrace();}catch (IOException e) {e.printStackTrace();}}}ClientDemo:Client.java(客户端主程序，直接运⾏):package cn.wjs;import java.io.IOException;import .InetAddress;import .Socket;import .UnknownHostException;public class Client{private static final int port = 9999;private static final String bindAddr = "127.0.0.1";public static void main(String[] args){System.out.println("正在连接Socket服务器");try {Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9998);System.out.println("已连接\n================");new ClientMessageSender(socket).start();new ClientMessageReceiver(socket).start();System.out.println("已启动");}catch (UnknownHostException e) {e.printStackTrace();}catch (IOException e) {e.printStackTrace();}}}ClientMessageReceiver.java:package cn.wjs;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.UnsupportedEncodingException;import .Socket;public class ClientMessageReceiver extends Thread{private Socket socket;public ClientMessageReceiver(Socket socket){this.socket = socket;}public void run(){try {BufferedReader reader = new BufferedReader(new InputStreamReader(this.socket.getInputStream(), "UTF-8")); String content = null;while (true) {if (this.socket.isClosed()) {System.out.println("Socket已经关闭");reader.close();this.socket.close();break;}content = reader.readLine();if (content.equals("bye")) {System.out.println("对⽅请求关闭连接,⽆法继续进⾏聊天");reader.close();this.socket.close();break;}System.out.println("【对⽅】" + content + "\n");}}catch (UnsupportedEncodingException e){e.printStackTrace();}catch (IOException e) {e.printStackTrace();}}}ClientMessageSender.java:package cn.wjs;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.io.UnsupportedEncodingException;import .Socket;public class ClientMessageSender extends Thread{private Socket socket;public ClientMessageSender(Socket socket){this.socket = socket;}public void run(){try {BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(this.socket.getOutputStream(), "UTF-8"));BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));String msg = null;while (true) {msg = reader.readLine();if (msg.toLowerCase().equals("exit")) {System.exit(0);}if (this.socket.isClosed()) {System.out.println("Socket已经关闭");writer.close();this.socket.close();break;}writer.write(msg);writer.newLine();writer.flush();}}catch (UnsupportedEncodingException e){e.printStackTrace();}catch (IOException e) {e.printStackTrace();}}}通过elicpse导出jar包直接运⾏，服务器端导出jar设置main.class为Server.java,客户端导出jar设置main.class为Client.java------这是传统的TCP/BIO模式.如果多个客户端向服务器发送请求，通常采⽤连接池的⽅式来维护,这和数据库的连接池⼀个道理。

ｉｎ ｆｉ ｂａｓ ｄ ｇ ｌｅ ｅ ｏｎ ＴＣ Ｐ ｐ ｔ ｏｌ ｒｏ ｏｃ ａｎ ｓ ｒｖ ｒ ｒ ｎｓ ｔｔｉ ｇ， Ｏ ｄ ｅ ｅ ｔ ａ ｍｉ ｎ Ｓ ｔｈ ｃ ｅ ｓ ａｔ ｌｉ ｎｔ ｓｅ ｄ ｎ ｆｉｌ ｓ ｅ ｔｈ ｔ ｅ
２ Ｓ ｃ ｅ 机 制 ｏｋｔ
两端通过 Ｓ ｃ ｅ ｏ ｋ ｔ机制进行连接 。 １１客户端编程流程 ． ①打开 Ｓ ｃ ｅ ， ｏ ｋ ｔ 新建一个 套接字
Ｓ ｃ ｅ 是面 向客 户 ／服务器模型设 计的， 网络上 的两 ｏｋ ｔ 个程序通过一个双向的通讯 连接 实现数据的交换 ， 个双 向 这
摘 要： 分析 了目前基于 Ｔ Ｐ Ｃ￣Ｐ的通信系统的现状与不足． 先进 的 Ｊ ｖ ｏ ｋｔ 术， 采用 ａａＳｃｅ 技 开发 出一个 Ｂｓ 式 的基于 Ｔ Ｐ ／模 Ｃ
协议 的网络通信系统。该 系统充分利用 了Ｊｖ ａａ的跨平 台性和 Ａ ｐｅ 体积小、功能强的特 性，结合 目前 已有 的典型通讯 软件 ｐ ｌｔ
Ｋ ｙ ｒｓ ｏｋ ｔ ／ ｏ ｅＭ ｌ ｉ ｌ ｈ ｅ ｄ ；Ｓ ｒ ｅ ｒｎ ｍ ｔ ｉ ｇ ｅｗｏｄ ：Ｓ ｃ ｅ ；Ｂ ＳＭ ｄ ， ｕ ｔｐ ｅ Ｔ ｒａ ｓ ｅ ｖ ｒＴ ａ ｓ ｉ ｔｎ
Ｏ 引 言
④为该普通套接字创建 输入和输 出流 ；
④从输入和输出流中读人或 写入 字节流， 进行相 应的处
Ｂ Ｓ ｂ ｓ ｄ ｅ ｗ ｒ ｃｍ ｕ ｉａ ｉｎ ｓ ｓ ｅ ｓ ｄ ｖ ｌ ｐ ｄ ｙ ｔ ｅ ａ ｖ ｎ ｅ ｅ ｈ ｉｕ ｏ ａ ａ Ｓ ｃ ｅ ， ｈ ｓ ｙｔ ｍ ／－ ａ ｅ ｎ ｔ ｏｋ ｏ ｍ ｎ ｃｔ ｏ ｙ ｔ ｍ ｉ ｅ ｅｏ ｅ ｂ ｈ ｄａ ｃ ｄ ｔ ｃ ｎ ｑ ｅ ｆ Ｊ ｖ ｏｋ ｔＴ ｉ ｓ ｓ ｅ

目录摘要 (1)1 前言 (1)2 可行性研究 (2)2.1开发背景 (2)2.2技术可行性分析 (2)2.3面临问题及现状 (2)2.4开发目的及意义 (3)2.5.1运行环境 (3)2.5.2性能要求 (3)3 需求分析 (3)3.1系统总体功能 (3)3.2开发工具以及使用的主要技术简介 (4)3.2.1数据库Microsoft SQL2000简介 (5)3.2.2 eclipse简介 (6)3.3客户机/服务期(C/S)工作原理 (7)3.4套接字(SOCKET)原理图 (8)3.5系统逻辑模式 (8)3 概要设计 (9)3.1客户端 (10)3.1.1 用户注册功能模块 (10)3.1.2发送消息功能模块 (11)3.1.3查找好友功能模块 (11)3.1.4 添加好友模块 (11)3.1.5删除好友模块 (12)3.1.6修改个人信息模块 (12)3.2服务器 (12)3.2.1用户登录模块设计 (13)3.2.2新用户注册模块设计 (14)3.2.3查找网友模块设计 (15)3.2.4添加好友模块设计 (16)3.2.5 用户之间发送数据模块设计 (17)3.3数据库设计 (18)3.3.1数据库结构设计 (19)3.3.2数据表设计 (19)3.3.3 数据字典 (21)(1) 聊天信息字典 (21)4 详细设计 (22)4.1服务器端 (22)4.1.1服务器建立和启动模块 (22)4.1.2 数据库交互模块 (23)4.1.3 处理客户端请求模块 (25)4.1.4 异常处理模块 (25)4.2客户端 (25)4.2.1 客户端与服务器建立连接模块 (25)4.2.2 用户登陆模块 (26)4.2.3 注册模块 (26)4.2.4 通讯模块 (27)4.2.5 聊天模块 (28)4.2.6 查找好友模块 (29)4.2.7个人信息模块 (30)5 总结 (32)参考文献 (33)致谢........................................... 错误!未定义书签。

摘要随着互联网的快速发展，网络聊天工具已经作为一种重要的信息交流工具，受到越来越多的网民的青睐.目前，出现了很多非常不错的聊天工具，其中应用比较广泛的有Netmeeting、腾讯QQ、MSN-Messager等等。

该系统开发主要包括一个网络聊天服务器程序和一个网络聊天客户程序两个方面。

前者通过Socket套接字建立服务器，服务器能读取、转发客户端发来信息，并能刷新用户列表。

后者通过与服务器建立连接，来进行客户端与客户端的信息交流。

其中用到了局域网通信机制的原理,通过直接继承Thread类来建立多线程。

开发中利用了计算机网络编程的基本理论知识，如TCP/IP协议、客户端/服务器端模式(Client/Server模式）、网络编程的设计方法等。

在网络编程中对信息的读取、发送，是利用流来实现信息的交换，其中介绍了对实现一个系统的信息流的分析,包含了一些基本的软件工程的方法。

经过分析这些情况，该局域网聊天工具采用Eclipse为基本开发环境和java 语言进行编写，首先可在短时间内建立系统应用原型，然后，对初始原型系统进行不断修正和改进，直到形成可行系统关键词：局域网聊天 socket javaAbstractAlong with the fast development of Internet，the network chating tool has already become one kind of important communication tools and received more and more web cams favor. At present, many extremely good chating tools have appeared . for example，Netmeeting, QQ，MSN—Messager and so on. This system development mainly includes two aspects of the server procedure of the network chat and the customer procedure of the network chat。