设计一个基于Socket结构的简易聊天程序。

package chat1

import java.awt.*

import javax.swing.*

import java.awt.event.*

import java.net.*

import java.io.*

public class Client extends JFrame{

/**

*

*/

private static final long serialVersionUID = -4733717749265129757L

Container con=null

JTextArea jta = null

JTextField jtf = null

//ArrayList al = new ArrayList()

//ServerSocket ss = null

Socket s = null

Client(String ip,int port){

try{

s=new Socket(ip,port)//创建一个流套接字并将其连接到指定 IP 地址的指定端口号。

launchFrame()

}

catch(Exception e){

e.printStackTrace()

}

new Thread(new ClientR()).start()

}

public void sent(String str){ //发送消息方法

try{

DataOutputStream dos = new DataOutputStream(s.getOutputStream())// 创建一个新的数据输出流，将数据写入指定 返回s的套接字的输出流。

dos.writeUTF(str)

}

catch(Exception e){

e.printStackTrace()

}

}

public void disconnect() throws Exception

{

s.close()//失去连接，关闭线程s

}

class ClientR implements Runnable{//客户端运行

/*Runnable 接口应该由那些打算通过某一线程执行其实例的类来实现。类必须定义一个称为 run 的无参数方法。

设计该接口的目的是为希望在活动时执行代码的对象提供一个公共协议。例如，Thread 类实现了 Runnable。

激活的意思是说某个线程已启动并且尚未停止。

此外，Runnable 为非 Thread 子类的类提供了弊竖一种激活方式。

通过实例化某个 Thread 实例并将自身作为运行目标，就可以运行实现 Runnable 的类而无需创建 Thread 的子类。

大多数情况下，如果只想重写 run() 方法，而不重写其他 Thread 方法，那么应使用 Runnable 接辩卜衡口。这很重要，

因为除非程序员打算携做修改或增强类的基本行为，否则不应为该类创建子类。

*/

public void run(){

try{

DataInputStream dis = new DataInputStream(s.getInputStream())//使用指定的底层 s.getInputStream（s的套接字的输入流） 创建一个 DataInputStream(数据输入流）

String str = dis.readUTF()

while(true){

System.out.println (str)

jta.append(str+"\n")

str = dis.readUTF()

}

}

catch(Exception e){

e.printStackTrace()

}

}

}

public void startClient(){ //客户端启用

try{

BufferedReader br = new BufferedReader(new InputStreamReader(System.in))//读取数据流

String str=br.readLine()

while(true){

sent(str)//发送数据

if(str.equals("q")){ //如果读取的字符为q

disconnect()//断开连接

return

}

str=br.readLine()

}

}

catch(Exception e){

e.printStackTrace()

}

}

public void launchFrame() throws IOException{ //客户端面板布局

con = this.getContentPane()

jta = new JTextArea()

jtf = new JTextField()

final JTextField jtf1=new JTextField(10)

final JButton jb=new JButton("确认")

Panel p=new Panel()

//Panel p1=new Panel()

JLabel jl=new JLabel()

jl.setText("your name:")

//jl.getVerticalTextPosition()

jtf1.setBackground(Color.PINK)

jtf1.setBounds(10, 10, 10, 10)

p.add(jl)

p.add(jtf1)

p.add(jb)

jb.addActionListener(new ActionListener(){

public void actionPerformed(ActionEvent e){

//e.getWhen()

e.getActionCommand()

jtf.setText(jtf1.getText().toString()+"say:")

}

})

jta.setBackground(Color.LIGHT_GRAY)

jta.setEditable(false)//不可编辑文本域

JScrollPane jsp = new JScrollPane(jta, //jta上滚动条的创建

JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,

JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED)

//con.add(jb,BorderLayout.WEST)

con.add(jsp,BorderLayout.CENTER)

con.add(p,BorderLayout.NORTH)

con.add(jtf,BorderLayout.SOUTH)

jtf.addActionListener(new ActionListener(){ ///事件监听

public void actionPerformed(ActionEvent e){

String str = jtf.getText().toString()

Client.this.sent(str)

jtf.setText(jtf1.getText().toString()+"say:")

}

})

this.setTitle("聊天客户端，袭风版")

this.setBounds(200,200,300,400)

this.setDefaultCloseOperation(EXIT_ON_CLOSE)

this.setBackground(Color.blue)

this.setVisible(true)

}

public static void main (String[] args) {

Client cli = new Client("127.168.1.1",3456)//创建一个客户端，并将其连接到指定 IP 地址的指定端口号，其端口号与服务器端一致。与服务器建立连接

cli.startClient()//127.0.0.1为本机端口

}

}

package chat1

import java.net.*

import java.io.*

import java.util.*

//import java.awt.event.*

import javax.swing.*

import java.awt.*

public class Server extends JFrame{

/**

* 套接字接口可分为三类：公认端口 注册端口 动态和/或私有端口

套接字，简单的说就是通信的两方的一种约定，用套接字中的相关函数来完成通信过程

*/

private static final long serialVersionUID = 4130666237241201704L

Container con = null//容器

JTextArea jta = null//文本区

ServerSocket ss = null//初始化服务器套接字

ArrayList al = new ArrayList()//ArrayList容器

Server(int port){ //构造函数

try{

ss=new ServerSocket(port)// 创建绑定到特定端口的服务器套接字。

}

catch(Exception e){

e.printStackTrace()

}

launchFrame()

}

public void severStart(){ //线程开始

while(true){

try{

Socket s = ss.accept()//侦听并接受到此套接字(port)的连接。

al.add(new ServerR(s))

jta.append("New Client:"+"\n Ip: "+s.getInetAddress()+":"+s.getPort()+"\n" //得到客户端本地地址，端口和客户端数量

+"Clients count:"+al.size()+"\n")

}

catch(Exception e){

e.printStackTrace()

}

}

}

class ServerR implements Runnable{

Socket s = null//创建新服务线程

ServerR(Socket s){

this.s = s

new Thread(this).start()//启动新线程

}

public void sent(String str){ //发送数据流方法

try{

DataOutputStream dos = new DataOutputStream(s.getOutputStream())//从s套接字中读出输出数据流

dos.writeUTF(str)//使用 UTF-8 修改版编码将一个字符串写入基础输出流。

}

catch(Exception e){

e.printStackTrace()

}

}

public void run(){

try{

DataInputStream dis = new DataInputStream(s.getInputStream())

String str = dis.readUTF()//读出输入的数据流

while(true){

// System.out.println (str)

Iterator ite = al.iterator()//生成list迭代器

while(ite.hasNext()){ //如果仍有可迭代的元素，返回true

((ServerR)ite.next()).sent(str)//返回(ServerR)的下一个元素，并发送它

//先遍历ServerR中的所有线程

}

str=dis.readUTF()

}

}

catch(Exception e){

try{ //客户端关闭捕捉

s.close()//关闭一个相关客户端线程

al.remove(this)//从迭代器指向的集合中移除迭代器返回的最后一个元素

jta.append("A client quit!\nClients count:"+al.size()+"\n")//统计客户端现有的数量

}

catch(Exception e2){

e2.printStackTrace()

}

e.printStackTrace()

}

}

}

public void launchFrame(){ //服务器端面板布局

con = this.getContentPane()

jta = new JTextArea()

jta.setEditable(false)//不可编辑文本域

JScrollPane jsp = new JScrollPane(jta,

JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,

JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED)

con.add(jsp,BorderLayout.CENTER)

this.setTitle("聊天服务端，袭风版")

this.setBounds(200,200,300,400)

this.setDefaultCloseOperation(EXIT_ON_CLOSE)

this.setVisible(true)

}

public static void main (String[] args) {

Server s = new Server(3456)//创建服务器S 端口为3456

s.severStart()

}

}

你好，很高兴回答你的问题。

两闭前个人拥有账号，调用了数据库。

聊天用到了软件时纯雹实传输，将打的字在单击发送的时候，通过传输线路，加密，到达服务器，通过服务器解密，再加密进行数据传输到达对方的窗做态帆口显示。

希望能够帮到你。

   MySQL并发能力强 响应速度快 是性能优异的数据库软件PHP是功能强大的服务器端脚本语言 笔者在山西铝厂网站开发中 采用PHP +MySQL 建立了多种应用 下面 以一个简单的聊天室设计为例 介绍PHP+MySQL在网页开发中的应用

     总体设计

     构思与规划:

    聊天室的基本原理 就是把每个连上同一网页的用户传送的发言数据储存起来 然后将所有的发言数据传给每一用户 也就是说 用数据库汇集每个人的发言 并将数据库中的数据传给每一个人就实现了聊天室的功能

     表设计

    首先使用MySQL建立表chat用来储存用户的发言:

    mysql>CREATE TABLE chat      >(chtime DATATIME      >nick CHAR( ) NOT NULL      >words CHAR( ))

    表中只设定了三个域 chtime是发言的时间 nick为发言者的昵称 words是发言的内容 发言最多 个字符

     网页设计

    一个最简单的聊天室通常需要两个页框:一个页框是用户输入发言的表单 另一个用来显示大家的发言 所以代码段通常至少需要如下几段:

    建立页框的结构(main php)

    显示大家发言的程序段(cdisplay php)

    传送用户发言的程序段(speak php)

    用户登录进入聊天室程序段(login php)

     代码设计

    以上规划完成后 就可以着手代码设计了 采用php可以非常简明实现以上的功能

     用户登录login php 本段代码是一个完全HTML网页

    ＜＞     ＜head＞     ＜title＞用户登录＜/title＞     ＜/head＞     ＜body＞请输入您的昵称＜br＞     ＜form action= main php method= post target= _self ＞     ＜input type= text name= nick cols= ＞     ＜input type= submit value= 登录 ＞     ＜/body＞     ＜/＞

    用户提交自己的昵称后 就进入到聊天室 以下的处理交由main php处理

     页框主体代码段main php:

    毕空＜?     setcookie( nick $nick) //用cookie记录用户昵称 是常用的传递变量方法     ?＞     ＜＞     ＜title＞山西铝厂聊天室试用版ver ＜/title＞     ＜frameset rows= % * ＞     ＜frame src= cdisplay php name= chatdisplay ＞     ＜frame src= speak php name= speak ＞     ＜/frameset＞     ＜/＞

     显示发言cdisplay php

    本代码段的任务是将表chat中的数据取出 显示在页框中 每次刷新时 取数据库中最近的 条发言 同时 为防止数据库无限增大 需设计删除陈旧数据的功能 代码手拦瞎如下

    ＜＞     ＜head＞     ＜title＞显示用户发言＜/title＞     ＜meta equiv= refresh content= url=cdisplay php ＞     ＜/head＞     ＜body＞     ＜?     $link_ID=mysql_connect( main root )    //链接Mysql服务器 服务器名为main 管理员名为root     mysql_select_db( abc )//选择数据库     $str= select * from chat ORDER BY chtime//查询字符串     $result=mysql_query($str $link_ID)//送出查询     $rows=mysql_num_rows($result)//取得查询结果的记录笔数     //取得最后 笔发言 并显示     @mysql_data_seek($resut $rows )//移动记录指针到前 笔记录     if ($rows＜ ) $l=$rowselse $l= //记录总数小于 则最多为该记录数     for ($i= $i＜=$l$i++) {  衡昌   list($chtime $nick $words)=mysql_fetch_row($result)    echo $chtimeecho echo $nickecho : echo $wordsecho ＜BR＞     }     //清除库中过时的数据     @mysql_data_seek($result $rows )//移动记录指针到前 笔记录     list($limtime)=mysql_fetch_row($result)    $str= DELETE FROM chat WHERE chtime＜ $limtime     $result=mysql_query($str $link_ID)//送出查询字符串 库中只留前 个记录     mysql_close($link_ID)    ?＞     ＜/body＞     ＜/＞

     送出发言到数据库speak php

    ＜＞     ＜head＞     ＜title＞发言＜/title＞     ＜/head＞     ＜body＞     ＜?     If ($words)     { $link_ID=mysql_connect( main root )    mysql_select_db( abc )//数据库名为abc     $time=date(y) date(m) date(d) date(h) date(i) (date(s)//取得当前时间     $str= INSERT INTO chat(chtime nick words) values ( $time $nick $words )    mysql_query($str $link_ID)//送出发言到数据库     mysql_close($link_ID)    }     ?＞     //输入发言的表单     ＜form action= speak php method= post target= _self ＞     ＜input type= text name= words cols= ＞     ＜input type= submit value= 发言 ＞     ＜/form＞     ＜/body＞     ＜/＞

lishixinzhi/Article/program/PHP/201311/21516

---