设计一个基于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()

}

}

用套接字：

服务端：创建套接字，绑定端口，监听，处理

客户端：创建套接字，建立连接，处理

服务端保存用户帐号密码好友群等资料，客户端登陆验证

然后聊天的话就把两个客户端都变成服务端进行点对点聊天或文件传输啦

为防止阻塞可能还需要用到多线程

MFC有封装好的socket

基本是这个过程啦，源码网上一大把

---