基于TCP的多人聊天小程序

Posted on 2007-05-24 20:31 久城 阅读(3550) 评论(8)  编辑  收藏 所属分类: JavaTest

要回家了,心就散了,毕业论文也做不下去了。闲着弄了弄Socket。同时遇到了一些问题。

服务端ChatServer.java

package com.neusoft.socket.chat;

import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {
    
// 存储不同客户端的线程
    public static Hashtable peopleList;

    
public static void main(String args[]) {
        ServerSocket server 
= null;
        Socket socket 
= null;

        peopleList 
= new Hashtable();
        
while (true{
            
try {
                
// 建立服务端
                server = new ServerSocket(8099);
            }
 catch (IOException e) {
            }

            
try {
                
// 开始监听
                socket = server.accept();
                InetAddress address 
= socket.getInetAddress();
                System.out.println(
"IP:" + address + " come in.");

            }
 catch (IOException e) {
            }

            
if (socket != null{
                
// 开启一条线程通讯
                new Server_thread(socket).start();
            }
 else {
                
continue;
            }

        }

    }

}


服务端线程Server_thread.java
package com.neusoft.socket.chat;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Enumeration;
import java.util.Hashtable;

public class Server_thread extends Thread {
    
// 客户端机器名
    String name = null;

    String keyName 
= null;

    String message 
= null;

    Socket socket 
= null;

    ObjectOutputStream out 
= null;

    ObjectInputStream in 
= null;

    Hashtable peopleList 
= null;

    
public Server_thread(Socket t) {
        socket 
= t;
        
try {
            
// 取得输入输出流对象
            in = new ObjectInputStream(socket.getInputStream());
            out 
= new ObjectOutputStream(socket.getOutputStream());
        }
 catch (IOException e) {
        }

    }


    
public void run() {

        
while (true{

            
try {
                
// 读取客户端消息
                message = (String) in.readObject();
                
// 把客户端线程存储到HASHTABLE
                name = socket.getInetAddress().toString();
                
if (!ChatServer.peopleList.containsKey(name)) {
                    ChatServer.peopleList.put(name, 
this);
                }


                
// 遍历HASHTABLE,把消息发送到每一个客户端,实现多人聊天
                Enumeration enum1 = ChatServer.peopleList.keys();
                
while (enum1.hasMoreElements()) {
                    keyName 
= (String) enum1.nextElement();
                    ((Server_thread) ChatServer.peopleList.get(keyName)).out
                            .writeObject(keyName 
+ "says:" + message);
                }

            }
 catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
 catch (IOException ee) {
                ee.printStackTrace();
            }

        }

    }

}

客户端:Client.java
package com.neusoft.socket.chat;

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import javax.swing.*;

public class Client extends JFrame {
    
private Container container;

    
private JTextField enterField;

    
private JTextArea displayArea;

    
private ObjectOutputStream output;

    
private ObjectInputStream input;

    
private String message = "";

    
private String chatServer;

    
private Socket client;

    
public Client(String host) {
        
//初始化聊天窗口
        super("my Client");
        chatServer 
= host;
        container 
= getContentPane();
        enterField 
= new JTextField();
        enterField.setEnabled(
false);
        enterField.addActionListener(
new ActionListener() {
            
public void actionPerformed(ActionEvent event) {
                sendData(event.getActionCommand());
            }

        }
);
        container.add(enterField, BorderLayout.SOUTH);
        displayArea 
= new JTextArea();
        container.add(
new JScrollPane(displayArea), BorderLayout.CENTER);
        setSize(
500300);
        setLocation(
200300);
        setVisible(
true);
    }


    
// 执行客户端
    public void runClient() {
        
try {
            connectToServer();
            getStreams();
            processConnection();
            closeConnection();
        }
 catch (EOFException eofException) {
            System.out.println(
"Server terminated connection");
        }
 catch (IOException e) {
            e.printStackTrace();
        }

    }


    
// 连接服务端
    private void connectToServer() throws IOException {
        displayArea.setText(
"Attempting connection\n");
        client 
= new Socket(InetAddress.getByName(chatServer), 8099);
        displayArea.append(
"Connection to: "
                
+ client.getInetAddress().getHostName());
    }


    
// 取得数据流
    private void getStreams() throws IOException {
        output 
= new ObjectOutputStream(client.getOutputStream());
        output.flush();
        input 
= new ObjectInputStream(client.getInputStream());
        displayArea.append(
"\nGot I/O streams\n");
    }


    
// 执行通信
    private void processConnection() throws IOException {
        enterField.setEnabled(
true);
        
do {

            
try {
                message 
= (String) input.readObject();
                displayArea.append(
"\n" + message);
                displayArea.setCaretPosition(displayArea.getText().length());
            }
 catch (ClassNotFoundException e) {
                e.printStackTrace();
            }


        }
 while (!message.equals("SERVER>>> TERMINATE"));
    }


    
// 关闭连接
    private void closeConnection() throws IOException {
        displayArea.append(
"\nClosing connection");
        output.close();
        input.close();
        client.close();
    }


    
// 发送消息
    private void sendData(String message) {
        
try {
            output.writeObject(
"child>>> " + message);
            output.flush();
            enterField.setText(
"");
        }
 catch (IOException e) {
            displayArea.append(
"\nError writing object");
        }

    }


    
public static void main(String args[]) {
        Client c 
= new Client("192.168.34.179");
        c.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        c.runClient();
    }

}

这样可以简单的实现局域网内通信。

但是形式还太简单。和朋友间用的话,朋友还得运行JAVA文件才可以。想作成可执行的文件。在网上查了查,好像有工具可以直接实现。可惜在公司,下不了那些软件。

所以想用别的方法。最先,我想把它嵌入到WEB中,结合javascript,jsp做了大半天。其中java,javacript,jsp之间的相互通信实在是让我头疼。越弄越复杂。后来,想写成Applet,后悔当初没有认真听Applet,弄了半天始终没有达到理想的效果。

先把代码贴下,回家继续改。

欢迎来访!^.^!
本BLOG仅用于个人学习交流!
目的在于记录个人成长.
所有文字均属于个人理解.
如有错误,望多多指教!不胜感激!

Feedback

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-05-25 09:27 by kk
用applet似乎也不通用。。。
applet在客户端中不能直接开socket,会有权限问题。。。

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-05-25 09:39 by 久城
原来如此。我昨天用Applet尝试了半天,始终连接不上服务端。一直不知道是哪里出错了。呵呵。

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-05-25 10:32 by L
你是学生?这种程序能支持几个用户呢。。多看看SEDA一类的框架吧。

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-05-25 13:08 by 久城
@L
:)工作的人和没工作的人考虑的事情就是不一样啊!我只考虑了实现通信,却没有想过程序的性能如何。好多想法还太单纯。
..恩,要看的东西还有好多。谢谢指点。

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-05-25 17:46 by pass86
应该是EASY的DEMO.

# re: 基于TCP的多人聊天小程序[未登录]  回复  更多评论   

2007-06-25 09:59 by 笨笨

我不喜欢JAVA 但老师要考试。没办法

# re: 基于TCP的多人聊天小程序[未登录]  回复  更多评论   

2007-06-25 10:00 by 笨笨

这个能用不?
先拷一下,
顺便说声:“谢谢”
哈哈

# re: 基于TCP的多人聊天小程序  回复  更多评论   

2007-11-26 12:01 by learner
同楼上 复制了一份 道谢!

只有注册用户登录后才能发表评论。


网站导航:
 

Copyright © 久城