java语音聊天源代码 java聊天室代码

急求一个关于UDP的JAVA实现多人聊天源代码

import java.io.InputStream;

import java.io.DataInputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.DataOutputStream;

import java.io.BufferedReader;

import java.net.ServerSocket;

import java.net.Socket;

import java.io.IOException;

import java.util.Date;

class Server

{

public Server()

{

try

{

ServerSocket s=new ServerSocket(8888);

Socket ss=s.accept();

OutputStream out=ss.getOutputStream();

DataOutputStream dout=new DataOutputStream(out);

InputStream in=ss.getInputStream();

DataInputStream din=new DataInputStream(in);

System.out.print(din.readUTF()+"!");

dout.writeUTF("你已经连接到服务器"+"\t"+"你的地址："+ss.getInetAddress()+"\t"

+"你的链接端口："+ss.getLocalPort()+"\n");

new ReadMessage(din).start();

new SendMessage(dout).start();

}

catch (IOException e)

{

e.printStackTrace();

}

}

public static void main(String[] args)

{

new Server();

}

}

//接受客户端信息

class ReadMessage extends Thread

{

private DataInputStream din;

public ReadMessage(DataInputStream din)

{

this.din=din;

}

public void run()

{

String str;

try

{

while (true)

{

str=din.readUTF();

System.out.println(new Date().toLocaleString()+"客户端说："+str);

if (str.equals("bye"))

{

System.out.println("客户端下线！");

break;

}

}

}

catch (IOException e)

{

e.printStackTrace();

}

}

}

// 发出服务器信息

class SendMessage extends Thread

{

private DataOutputStream dout;

public SendMessage(DataOutputStream dout)

{

this.dout=dout;

}

public void run()

{

InputStreamReader inr=new InputStreamReader(System.in);

BufferedReader buf=new BufferedReader(inr);

String str;

try

{

while(true)

{

str=buf.readLine();

dout.writeUTF(str);

if (str.equals("bye"))

{

System.out.println("服务器退出！");

System.exit(1);

}

}

}

catch (IOException e)

{

e.printStackTrace();

}

}

}

import java.io.InputStream;

import java.io.DataInputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.DataOutputStream;

import java.io.BufferedReader;

import java.net.Socket;

import java.io.IOException;

import java.util.Date;

class Client

{

public Client()

{

try

{

Socket s=new Socket("192.168.1.2",8888);

InputStream in=s.getInputStream();

DataInputStream din=new DataInputStream(in);

OutputStream out=s.getOutputStream();

DataOutputStream dout=new DataOutputStream(out);

dout.writeUTF("服务器你好！我是客户端");

System.out.println(din.readUTF());

new Thread(new SenderMessage(dout)).start();

new Thread(new ReaderMessage(din)).start();

}

catch (IOException e)

{

e.printStackTrace();

}

}

public static void main(String[] args)

{

new Client();

}

}

class ReaderMessage implements Runnable

{

private DataInputStream din;

public ReaderMessage(DataInputStream din)

{

this.din=din;

}

public void run()

{

String str;

try

{

while(true)

{

str=din.readUTF();

System.out.println(new Date().toLocaleString()+"服务器说："+str);

if (str.equals("bye"))

{

System.out.println("服务器已经关闭，此程序自动退出！");

break;

}

}

}

catch (IOException e)

{

e.printStackTrace();

}

}

}

class SenderMessage implements Runnable

{

private DataOutputStream dout;

public SenderMessage(DataOutputStream dout)

{

this.dout=dout;

}

public void run()

{

String str;

InputStreamReader inf=new InputStreamReader(System.in);

BufferedReader buf=new BufferedReader(inf);

try

{

while (true)

{

str=buf.readLine();

dout.writeUTF(str);

if (str.equals("bye"))

{

System.out.println("客户端自己退出！");

System.exit(1);

}

}

}

catch (IOException e)

{

e.printStackTrace();

}

}

}

相关问答

Q1: java 聊天室 源代码

【ClientSocketDemo.java 客户端Java源代码】

import java.net.*;

import java.io.*;

public class ClientSocketDemo

{

//声明客户端Socket对象socket

Socket socket = null;

//声明客户器端数据输入输出流

DataInputStream in;

DataOutputStream out;

//声明字符串数组对象response，用于存储从服务器接收到的信息

String response[];

//执行过程中，没有参数时的构造方法，本地服务器在本地，取默认端口10745

public ClientSocketDemo()

{

try

{

//创建客户端socket，服务器地址取本地，端口号为10745

socket = new Socket("localhost",10745);

//创建客户端数据输入输出流，用于对服务器端发送或接收数据

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

//获取客户端地址及端口号

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

//向服务器发送数据

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

//从服务器接收数据

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

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

}

//执行过程中，有一个参数时的构造方法，参数指定服务器地址，取默认端口10745

public ClientSocketDemo(String hostname)

{

try

{

//创建客户端socket，hostname参数指定服务器地址，端口号为10745

socket = new Socket(hostname,10745);

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

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

}

//执行过程中，有两个个参数时的构造方法，第一个参数hostname指定服务器地址

//第一个参数serverPort指定服务器端口号

public ClientSocketDemo(String hostname,String serverPort)

{

try

{

socket = new Socket(hostname,Integer.parseInt(serverPort));

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

String ip = String.valueOf(socket.getLocalAddress());

String port = String.valueOf(socket.getLocalPort());

out.writeUTF("Hello Server.This connection is from client.");

out.writeUTF(ip);

out.writeUTF(port);

response = new String[3];

for (int i = 0; i response.length; i++)

{

response[i] = in.readUTF();

System.out.println(response[i]);

}

}

catch(UnknownHostException e){e.printStackTrace();}

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

}

public static void main(String[] args)

{

String comd[] = args;

if(comd.length == 0)

{

System.out.println("Use localhost(127.0.0.1) and default port");

ClientSocketDemo demo = new ClientSocketDemo();

}

else if(comd.length == 1)

{

System.out.println("Use default port");

ClientSocketDemo demo = new ClientSocketDemo(args[0]);

}

else if(comd.length == 2)

{

System.out.println("Hostname and port are named by user");

ClientSocketDemo demo = new ClientSocketDemo(args[0],args[1]);

}

else System.out.println("ERROR");

}

}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

【ServerSocketDemo.java 服务器端Java源代码】

import java.net.*;

import java.io.*;

public class ServerSocketDemo

{

//声明ServerSocket类对象

ServerSocket serverSocket;

//声明并初始化服务器端监听端口号常量

public static final int PORT = 10745;

//声明服务器端数据输入输出流

DataInputStream in;

DataOutputStream out;

//声明InetAddress类对象ip，用于获取服务器地址及端口号等信息

InetAddress ip = null;

//声明字符串数组对象request，用于存储从客户端发送来的信息

String request[];

public ServerSocketDemo()

{

request = new String[3]; //初始化字符串数组

try

{

//获取本地服务器地址信息

ip = InetAddress.getLocalHost();

//以PORT为服务端口号，创建serverSocket对象以监听该端口上的连接

serverSocket = new ServerSocket(PORT);

//创建Socket类的对象socket，用于保存连接到服务器的客户端socket对象

Socket socket = serverSocket.accept();

System.out.println("This is server:"+String.valueOf(ip)+PORT);

//创建服务器端数据输入输出流，用于对客户端接收或发送数据

in = new DataInputStream(socket.getInputStream());

out = new DataOutputStream(socket.getOutputStream());

//接收客户端发送来的数据信息，并显示

request[0] = in.readUTF();

request[1] = in.readUTF();

request[2] = in.readUTF();

System.out.println("Received messages form client is:");

System.out.println(request[0]);

System.out.println(request[1]);

System.out.println(request[2]);

//向客户端发送数据

out.writeUTF("Hello client!");

out.writeUTF("Your ip is:"+request[1]);

out.writeUTF("Your port is:"+request[2]);

}

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

}

public static void main(String[] args)

{

ServerSocketDemo demo = new ServerSocketDemo();

}

}

Q2: 让Java说话－用Java实现语音引擎

为应用程序加上语音能力有什么好处呢？粗略地讲 是为了趣味 它适合所有注重趣味的应用 比如游戏 当然 从更严肃的角度来讲 它还涉及到应用的可用性问题 注意 这里我考虑的不仅是可视化界面固有的不足 而且还有这样一些情形 一些时候 让双眼离开当前的工作很不方便 甚至是不合法的 比如 假设有一个带语音功能的浏览器 你就可以在外出散步或开车上班的同时 用听的方式浏览自己喜爱的网站 从目前来看 邮件阅读器或许是语音技术更实际的应用 在JavaMail API的帮助下 这一切已经可能 邮件阅读器可以定期地检查收件箱 然后用语音 You have new mail would you like me to read it to you? 引起你的注意 按照类似的思路 我们还可以考虑一个带语音功能的提醒器 把它连接到一个日历应用 它会及时地提醒你 Don t fet your meeting with the boss in minutes! 也许你已经被这些主意吸引 或者有了自己更好的主意 现在让我们继续 首先我将介绍如何启用本文提供的语音引擎 这样 如果你认为语音引擎的实现细节过于复杂 就可以直接使用它而忽略其实现细节 一 试用语音引擎 要使用这个语音引擎 你必须在CLASSPATH中加入本文提供的javatalk jar文件 然后从命令行运行（或者从Java程序调用） lotontech speech Talker类 如果从命令行运行 则命令为 java lotontech speech Talker h|e|l|oo 如果从Java程序调用 则代码为 lotontech speech Talker talker=new lotontech speech Talker(); talker sayPhoneWord( h|e|l|oo ); 现在 对于在命令行上（或者调用sayPhoneWord()方法时）提供的 h|e|l|oo 字符串 你或许有所不解 下面我就来解释一下 语音引擎的工作原理是把细小的声音样本连接起来 每一个样本都是人的语言发音（英语）的一个最小单位 这些声音样本称为音素（allophone） 每一个因素对应一个 二个或者三个字母 从前面 hello 的语音表示可以看出 一些字母组合的发音显而易见 还有一些却不是很明显 h 读音显而易见 e 读音显而易见 l 读音显而易见 但注意两个 l 被简缩成了一个 l OO 应该读作 hello 中的读音 不应读作 bot too 中的读音 下面是一个有效音素的清单 a 如cat b 如cab c 如cat d 如dot e 如bet f 如frog g 如frog h 如hog i 如pig j 如jig k 如keg l 如leg m 如met n 如begin o 如not p 如pot r 如rot s 如sat t 如sat u 如put v 如have w 如wet y 如yet z 如zoo aa 如fake ay 如hay ee 如bee ii 如high oo 如go bb b的变化形式 重音不同 dd d的变化形式 重音不同 ggg g的变化形式 重音不同 hh h的变化形式 重音不同 ll l的变化形式 重音不同 nn n的变化形式 重音不同 rr r的变化形式 重音不同 tt t的变化形式 重音不同 yy y的变化形式 重音不同 ar 如car aer 如care ch 如which ck 如check ear 如beer er 如later err 如later (长音) ng 如feeding or 如law ou 如zoo ouu 如zoo (长音) ow 如cow oy 如boy sh 如shut th 如thing dth 如this uh u 的变化形式 wh 如where zh 如Asian 人说话的时候 语音在整个句子之内起落变化 语调变化使得语音更自然 更富有感染力 使得问句和陈述句能够相互区别 请考虑下面两个句子 It is fake f|aa|k Is it fake? f|AA|k 也许你已经猜想到 提高语调的方法是使用大写字母 以上就是使用该软件时你需要了解的东西 如果你对其后台实现细节感兴趣 请继续阅读 二 实现语音引擎 语音引擎的实现只包括一个类 四个方法 它利用了J SE 包含的Java Sound API 在这里 我不准备全面地介绍这个API 但你可以通过实例学习它的用法 Java Sound API并不是一个特别复杂的API 代码中的注释将告诉你必须了解的知识 下面是Talker类的基本定义 package lotontech speech; import javax sound sampled *; import java io *; import java util *; import *; public class Talker { private SourceDataLine line=null; } 如果从命令行执行Talker 下面的main()方法将作为入口点运行 main()方法获取第一个命令行参数 然后把它传递给sayPhoneWord()方法 /* * 读出在命令行中指定的表示读音的字符串 */ public static void main(String args[]) { Talker player=new Talker(); if (args length ) player sayPhoneWord(args[ ]); System exit( ); } sayPhoneWord()方法既可以通过上面的main()方法调用 也可以在Java程序中直接调用 从表面上看 sayPhoneWord()方法比较复杂 其实并非如此 实际上 它简单地遍历所有单词的语音元素（在输入字符串中语音元素以 | 分隔） 通过一个声音输出通道一个元素一个元素地播放出来 为了让声音更自然一些 我把每一个声音样本的结尾和下一个声音样本的开头合并了起来 /* * 读出指定的语音字符串 */ public void sayPhoneWord(String word) { // 为上一个声音构造的模拟byte数组 byte[] previousSound=null; // 把输入字符串分割成单独的音素 StringTokenizer st=new StringTokenizer(word | false); while (st hasMoreTokens()) { // 为音素构造相应的文件名字 String thisPhoneFile=st nextToken(); thisPhoneFile= /allophones/ +thisPhoneFile+ au ; // 从声音文件读取数据 byte[] thisSound=getSound(thisPhoneFile); if (previousSound!=null) { // 如果可能的话 把前一个音素和当前音素合并 int mergeCount= ; if (previousSound length= thisSound length= ) mergeCount= ; for (int i= ; i{ previousSound[previousSound length mergeCount+i] =(byte)((previousSound[previousSound length mergeCount+i]+thisSound[i])/ ); } // 播放前一个音素 playSound(previousSound); // 把经过截短的当前音素作为前一个音素 byte[] newSound=new byte[thisSound length mergeCount]; for (int ii= ; iinewSound[ii]=thisSound[ii+mergeCount]; previousSound=newSound; } else previousSound=thisSound; } // 播放最后一个音素 清理声音通道 playSound(previousSound); drain(); } 在sayPhoneWord()的后面 你可以看到它调用playSound()输出单个声音样本（即一个音素） 然后调用drain()清理声音通道 下面是playSound()的代码 /* * 该方法播放一个声音样本 */ private void playSound(byte[] data) { if (data length ) line write(data data length); } 下面是drain()的代码 /* * 该方法清理声音通道 */ b lishixinzhi/Article/program/Java/JSP/201311/19532

Q3: Java简单聊天程序

package com.kum.im.hrserver.test;

import java.net.*;

import java.nio.*;

import java.nio.channels.*;

import java.nio.charset.*;

import java.awt.*;

import java.awt.event.*;

public class ChatClient {

private SocketChannel sc = null;

private String name = null;

private Frame f;

private TextArea ta;

private TextField tf;

private boolean runnable = true;

public static void main(String[] args){

ChatClient cc = new ChatClient();

cc.createUI();

cc.inputName();

cc.connect();

new ReceiveThread(cc,cc.getTextArea()).start();

}

public SocketChannel getSc(){

return sc;

}

public void setName(String name){

this.name = name;

}

public TextArea getTextArea(){

return ta;

}

public TextField getTextField(){

return tf;

}

public boolean getRunnable(){

return runnable;

}

public void stop(){

runnable = false;

}

public void shutDown(){

try{

sc.write(ByteBuffer.wrap("bye".getBytes("UTF-8")));

ta.append("Exit in 5 seconds!");

this.stop();

Thread.sleep(5000);

sc.close();

}catch(Exception e){

e.printStackTrace();

}

System.exit(0);

}

public void createUI(){

f = new Frame("Client");

ta = new TextArea();

ta.setEditable(false);

tf = new TextField();

Button send = new Button("Send");

Panel p = new Panel();

p.setLayout(new BorderLayout());

p.add(tf,"Center");

p.add(send,"East");

f.add(ta,"Center");

f.add(p,"South");

MyClientListener listener = new MyClientListener(this);

send.addActionListener(listener);

tf.addActionListener(listener);

f.addWindowListener(new WindowAdapter(){

public void windowClosing(WindowEvent e){

ChatClient.this.shutDown();

}

});

f.setSize(400,400);

f.setLocation(600,0);

f.setVisible(true);

tf.requestFocus();

}

public boolean connect(){

try{

sc = SocketChannel.open();

//"zlg"为目标计算机名

InetSocketAddress isa = new InetSocketAddress("192.168.1.43",8814);

sc.connect(isa);

sc.configureBlocking(false);

sc.write(ByteBuffer.wrap(name.getBytes("UTF-8")));

}catch(Exception e){

e.printStackTrace();

}

return true;

}

public void inputName(){

String name = javax.swing.JOptionPane.showInputDialog("Input Your Name:");

this.setName(name);

f.setTitle(name);

}

}

class MyClientListener implements ActionListener{

private ChatClient client;

public MyClientListener(ChatClient client){

this.client = client;

}

public void actionPerformed(ActionEvent e){

TextField tf = client.getTextField();

String info = tf.getText();

if(info.equals("bye")){

client.shutDown();

}else{

try{

client.getSc().write(ByteBuffer.wrap(info.getBytes("UTF-8")));

}catch (Exception e1) {

e1.printStackTrace();

}

}

tf.setText("");

tf.requestFocus();

}

}

class ReceiveThread extends Thread{

private ChatClient client;

private TextArea ta;

public ReceiveThread(ChatClient client,TextArea ta){

this.client = client;

this.ta = ta;

}

public void run(){

SocketChannel sc = client.getSc();

ByteBuffer byteBuffer = ByteBuffer.allocate(2048);

CharBuffer charBuffer = null;

Charset charset = Charset.forName("UTF-8");

CharsetDecoder decoder = charset.newDecoder();

String msg = null;

int n = 0;

try{

while(client.getRunnable()){

n = sc.read(byteBuffer);

if(n0){

byteBuffer.flip();

charBuffer = decoder.decode(byteBuffer);

msg = charBuffer.toString();

ta.append(msg + "\n");

}

byteBuffer.clear();

Thread.sleep(500);

}

}catch(Exception e){

e.printStackTrace();

System.exit(0);

}

}

}

import java.io.*;

import java.nio.*;

import java.nio.channels.*;

import java.nio.charset.*;

import java.net.*;

import java.util.*;

public class ICQServer {

private Selector selector = null;

private ServerSocketChannel ssc = null;

//服务器端通信端口号

private int port = 8814;

//在线用户列表

private HashtableString, SocketChannel userList = null;

public ICQServer() {}

public ICQServer(int port) {

this.port = port;

}

//初始化服务器

public void init() {

try {

//创建选择器对象

selector = Selector.open();

//创建ServerSocketChannel

ssc = ServerSocketChannel.open();

//设置ServerSocketChannel为非阻塞模式

ssc.configureBlocking(false);

InetAddress ip = InetAddress.getLocalHost();

System.out.println("主机地址 -------- " + ip);

InetSocketAddress isa = new InetSocketAddress(ip, port);

//将与本通道相关的服务器套接字对象绑定到指定地址和端口

ssc.socket().bind(isa);

//创建在线用户列表

userList = new HashtableString, SocketChannel ();

}

catch (IOException e) {

System.out.println("初始化服务器时异常，原因 -------- " + e.getMessage());

}

}

//启动服务器

public void start() {

try {

//将ServerSocketChannel注册到Selector上，准备接收新连接请求

SelectionKey acceptKey = ssc.register(selector, SelectionKey.OP_ACCEPT);

SocketChannel sc;

int n;

String name; //用户名

String msg; //用户发言信息

while (true) {

//选择当前所有处于就绪状态的通道所对应的选择键,并将这些键组成已选择键集

n = selector.select(); //n为已选择键集中键的个数

if (n 0) {

//获取此选择器的已选择键集。

Set readyKeys = selector.selectedKeys();

Iterator it = readyKeys.iterator();

//遍历当前已选择键集

while (it.hasNext()) {

SelectionKey key = (SelectionKey) it.next();

//从当前已选择键集中移除当前键，避免重复处理

it.remove();

//如果当前键对应的通道已准备好接受新的套接字连接

if (key.isAcceptable()) {

//获取当前键对应的可选择通道（ServerSocketChannel）

ssc = (ServerSocketChannel) key.channel();

//接收新的套接字连接请求，返回新建的SocketChannel

sc = (SocketChannel) ssc.accept();

//如果有新用户接入

if (sc != null) {

//接收新上线用户姓名

name = readMessage(sc);

//设置新建的SocketChannel为非阻塞模式

sc.configureBlocking(false);

//将新建的SocketChannel注册到Selector上，准备进行数据"写"操作，

//并将当前用户名以附件的方式附带记录到新建的选择键上。

SelectionKey newKey = sc.register(selector,

SelectionKey.OP_WRITE, name);

//将新上线用户信息加入到在线用户列表

userList.put(name, sc);

//发送"新用户上线"通知

transmitMessage(name + " in!", "--Server Info--");

}

}

//否则，如果当前键对应的通道已准备好进行"写"操作

else if (key.isWritable()) {

//获取当前键对应的可选择通道（SocketChannel）

sc = (SocketChannel) key.channel();

//接收该通道相应用户的发言信息

msg = readMessage(sc);

//获取选择键上附带记录的当前用户名

name = key.attachment().toString();

//如果用户提出要下线

if (msg.equals("bye")) {

//从在线用户列表中移除当前用户

userList.remove(name);

//注销当前选择键对应的注册关系

key.cancel();

//关闭当前可选择通道

sc.close();

//发送"用户下线"通知

transmitMessage(name + " out!", "--Server Info--");

}

//否则，如果接收到的用户发言信息非空（""）

else if (msg.length() 0) {

//转发用户发言信息

transmitMessage(msg, name);

}

}

}

}

//延时循环，降低服务器端处理负荷

Thread.sleep(500);

}

}

catch (Exception e) {

System.out.println("启动服务器时异常，原因 -------- " + e.getMessage());

}

}

//转发用户发言信息

public void transmitMessage(String msg, String name) {

try {

ByteBuffer buffer = ByteBuffer.wrap( (name + ":" + msg).getBytes("UTF-8"));

//将字节数组包装到缓冲区中

Collection channels = userList.values();

SocketChannel sc;

for (Object o : channels) {

sc = (SocketChannel) o;

sc.write(buffer);

//将缓冲区数据写入聊天面板(TextArea)

buffer.flip();

//将缓冲区ByteBuffer的极限值设置为当前数据实际大小，将缓冲区的值设置为0

}

}

catch (Exception e) {

System.out.println("转发用户发言信息时异常，原因 -------- " + e.getMessage());

}

}

//接收用户发言信息

public String readMessage(SocketChannel sc) {

String result = null;

int n = 0;

ByteBuffer buf = ByteBuffer.allocate(1024);

try {

n = sc.read(buf);

buf.flip();

Charset charset = Charset.forName("UTF-8");

CharsetDecoder decoder = charset.newDecoder();

CharBuffer charBuffer = decoder.decode(buf);

result = charBuffer.toString();

}

catch (IOException e) {

System.out.println("接收用户发言信息时异常，原因 -------- " + e.getMessage());

}

return result;

}

public static void main(String args[]) {

ICQServer server = new ICQServer();

server.init();

server.start();

}

}

Q4: 急需一个java编程实现的简单聊天窗口代码

import java.awt.*;

import java.awt.event.*;

import javax.swing.*;

import java.net.*;

import java.io.*;

public class ClientDemo01 {

public static void main(String[] args){

JFrame f=new JFrame("AA");

JPanel p1=new JPanel();

JPanel p2=new JPanel();

JTextArea ta=new JTextArea(15,30);

ta.setEditable(false); //文本域只读

JScrollPane sp=new JScrollPane(ta); //滚动窗格

JTextField tf=new JTextField(20);

JButton b=new JButton("发送");

p1.add(sp);

p2.add(tf);

p2.add(b);

f.add(p1,"Center");

f.add(p2,"South");

f.setBounds(300,300,360,300);

f.setVisible(true);

f.setResizable(false);

f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

Socket socket=null;

BufferedInputStream bis=null;

BufferedOutputStream bos=null;

try{

socket=new Socket("192.168.0.4",5000);

bis=new BufferedInputStream(socket.getInputStream());

bos=new BufferedOutputStream(socket.getOutputStream());

MyThread01 mt=new MyThread01(bis,ta);

mt.start();

}catch(Exception e){

e.printStackTrace();

}

b.addActionListener(new ButtonActionListener01(tf,ta,bos));

}

}

class ButtonActionListener01 implements ActionListener{

JTextField tf;

JTextArea ta;

BufferedOutputStream bos;

public ButtonActionListener01(JTextField tf,JTextArea ta,BufferedOutputStream bos){

this.tf=tf;

this.ta=ta;

this.bos=bos;

}

public void actionPerformed(ActionEvent e){

String message=tf.getText();

if(!message.equals("")){

tf.setText(""); //清空文本框

ta.append("AA:"+message+"\n"); //添加到文本域并换行

try{

bos.write(message.getBytes());

bos.flush();

}catch(Exception ex){

System.out.println("发送失败");

}

}

}

}

class MyThread01 extends Thread{

BufferedInputStream bis;

JTextArea ta;

public MyThread01(BufferedInputStream bis,JTextArea ta){

this.bis=bis;

this.ta=ta;

}

public void run(){

try{

while(true){

byte[] b=new byte[100];

int length=bis.read(b);

String message=new String(b,0,length);

ta.append("BB:"+message+"\n");

}

}catch(Exception e){

e.printStackTrace();

}

}

} import java.awt.*;

import java.awt.event.*;

import javax.swing.*;

import java.net.*;

import java.io.*;

public class ServerDemo01{

public static void main(String[] args){

JFrame f=new JFrame("BB");

JPanel p1=new JPanel();

JPanel p2=new JPanel();

JTextArea ta=new JTextArea(12,30); //文本域，第一个参数为行数，第二个参数为列数

ta.setEditable(false); //文本域只读

JScrollPane sp=new JScrollPane(ta); //滚动窗格

JTextField tf=new JTextField(20);

JButton b=new JButton("发送");

p1.add(sp);

p2.add(tf);

p2.add(b);

f.add(p1,"Center");

f.add(p2,"South");

f.setBounds(300,300,360,300);

f.setVisible(true);

f.setResizable(false);

f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

ServerSocket server=null;

Socket socket=null;

BufferedInputStream bis=null;

BufferedOutputStream bos=null;

try{

server=new ServerSocket(5000);

//ta.append("等待AA连接...\n");

socket=server.accept();

//ta.append("AA已连接\n");

bis=new BufferedInputStream(socket.getInputStream());

bos=new BufferedOutputStream(socket.getOutputStream());

MyThread1 mt=new MyThread1(bis,ta);

mt.start();

}catch(Exception e){

e.printStackTrace();

}

b.addActionListener(new ButtonActionListener1(tf,ta,bos));

}

}

class ButtonActionListener1 implements ActionListener{

JTextField tf;

JTextArea ta;

BufferedOutputStream bos;

public ButtonActionListener1(JTextField tf,JTextArea ta,BufferedOutputStream bos){

this.tf=tf;

this.ta=ta;

this.bos=bos;

}

public void actionPerformed(ActionEvent e){

String message=tf.getText(); //获取文本框中的内容

if(!message.equals("")){

tf.setText(""); //清空文本框

ta.append("BB:"+message+"\n"); //添加到文本域并换行

try{

bos.write(message.getBytes());

bos.flush();

}catch(Exception ex){

System.out.println("发送失败！");

}

}

}

}

class MyThread1 extends Thread{

BufferedInputStream bis;

JTextArea ta;

public MyThread1(BufferedInputStream bis,JTextArea ta){

this.bis=bis;

this.ta=ta;

}

public void run(){

try{

while(true){

byte[] b=new byte[100];

int length=bis.read(b);

String message=new String(b,0,length);

ta.append("AA:"+message+"\n");

}

}catch(Exception e){

e.printStackTrace();

}

}

}

Q5: 请问能不能帮我写一个Java的聊天窗口文件源代码，不要很复杂，只要能运行，聊天就行了！我用淘宝金币换,谢

话说网上真java语音聊天源代码的好多啊...

package client;

import java.awt.Color;

import java.awt.Container;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.util.Date;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

public class ClientFrame extends JFrame{

private JTextArea allmsg;

private JTextField welcome,copyright,chatmsg;

private JButton send;

private JScrollPane js;

private boolean isConnected = true;

public DataOutputStream out;

public DataInputStream in;

public Socket s = null;

String nic; /* -- 保存用户昵称 --*/

/**

* 初始化客户端资源

* 1.获取从LoginFrame传递过来的参数

* 2.初始化界面元素

* 3.初始化通信所需要的资源 EGjava语音聊天源代码：输入/输出流(DataInputStream/DataOutputStream)

* */

public ClientFrame(String name,Socket socket)

{

this.setSize(310,660);

this.setLocation(290,50);

this.setTitle("聊天室客户端"+name+"");/* -- 指定窗口的标题 --*/

this.s = socket;/* -- 接收从LoginFrame中传递过来的Socket --*/

this.nic = name+" 说： ";

welcome = new JTextField(" "+name+" 欢迎您来到聊天室 ",100);

welcome.setBackground(Color.blue);

welcome.setEnabled(false);

copyright = new JTextField(" ----- all copyright @ TOP-king -----");

copyright.setEnabled(false);

allmsg = new JTextArea();

allmsg.setEditable(false);

allmsg.append(" 系统消息: 欢迎登录在线聊天室 \n");

js = new JScrollPane(allmsg);//为JTextArea添加滚动条

chatmsg = new JTextField("在此输入聊天信息");

chatmsg.addActionListener(new listen());

send = new JButton("发送");

send.addActionListener(new listen());/* -- 添加事件监听器 --*/

try {

out = new DataOutputStream(s.getOutputStream());

in = new DataInputStream(s.getInputStream());

} catch (IOException e) {JOptionPane.showMessageDialog(null, "系统异常","错误",JOptionPane.OK_CANCEL_OPTION);}

addcomponettocontainer();

/* -- 当用户关闭窗口时进行相关的处理 eg:Socket Data(Input/Output)Stream 的关闭--*/

this.addWindowListener(new WindowAdapter(){

public void windowClosing(WindowEvent we)

{

sendmsg("quitlogout");/* -- 向服务器端发送关闭信息 --*/

isConnected = false;

destory();/* -- 销毁窗口资源 --*/

}

});

new Thread(new linread()).start();/* -- 启动读取信息线程 --*/

}

public void addcomponettocontainer()

{

Container c = this.getContentPane();

c.setLayout(null);

welcome.setBounds(75,10,150,20);

js.setBounds(10,50,280,500);

chatmsg.setBounds(10,560,180,30);

send.setBounds(220,560,70,30);

copyright.setBounds(10,600,280,20);

c.add(welcome);

c.add(js);

c.add(chatmsg);

c.add(send);

c.add(copyright);

this.setVisible(true);

this.setResizable(false);

}

class listen implements ActionListener

{

public void actionPerformed(ActionEvent e) {

// TODO Auto-generated method stub

if(e.getSource()==send||e.getSource()==chatmsg)

{

String msg = chatmsg.getText().trim();

if("".equals(msg))

{

JOptionPane.showMessageDialog(null,"发送信息不能为空!","错误",JOptionPane.OK_OPTION);

}

else

{sendmsg((new Date()).toLocaleString()+"\n"+nic+msg+"\n");chatmsg.setText("");}

}

}

}

/* -- 向服务器端发送信息 --*/

public void sendmsg(String m)

{

if(isConnected)//如果socket的输出流没关闭

{

try {

out.writeUTF(m);

} catch (IOException e) {

JOptionPane.showMessageDialog(null,"发送信息失败!(系统异常)","错误",JOptionPane.OK_OPTION);

}

}

else

{

JOptionPane.showMessageDialog(null,"发送信息失败!(服务器关闭/网络故障)","错误",JOptionPane.OK_OPTION);

}

}

/* -- 读取信息线程 --*/

class linread implements Runnable

{

public void run()

{

read();

}

public void read()

{

while(isConnected)

{

try {

String msg = in.readUTF();

if("SYSTEM_CLOSED".equals(msg))

{

JOptionPane.showMessageDialog(null,"读取消息失败(服务器关闭/网络故障)！","错误",JOptionPane.OK_OPTION);

isConnected = false;

}

else

allmsg.append(msg+"\n");

} catch (IOException e) {

}

}//end while

JOptionPane.showMessageDialog(null,"读取消息失败(服务器关闭/网络故障)！","错误",JOptionPane.OK_OPTION);

}//end read()

}

public void destory()

{

try {

this.out.close();

this.in.close();

this.s.close();

} catch (IOException e) {

}

this.dispose();

}

}

======================================================

package client;

import java.awt.*;

import javax.swing.*;

import java.awt.event.*;

import java.io.*;

import java.net.*;

public class LoginFrame extends JFrame{

private JTextField name;

private JTextField ip;

private JButton ok,cancle;

public Socket socket;

public LoginFrame()

{

super("登录框");

this.setSize(400,80);

this.setLocation(100,100);

name = new JTextField("昵称");

ip = new JTextField("127.0.0.1");

ok = new JButton("登录");

cancle = new JButton("取消");

ok.addActionListener(new listenEvent());

cancle.addActionListener(new listenEvent());

//建立容器

addcomponettocontainer();

this.setDefaultCloseOperation(EXIT_ON_CLOSE);

}

/**

* 建立容器及控件

*/

public void addcomponettocontainer()

{

Container c = this.getContentPane();

c.setLayout(null);

name.setBounds(10,10,100,30);

ip.setBounds(120,10,100,30);

ok.setBounds(230,10,70,30);

cancle.setBounds(310,10,70,30);

c.add(name);

c.add(ip);

c.add(ok);

c.add(cancle);

this.setVisible(true);

this.setResizable(false);

}

public class listenEvent implements ActionListener

{

public void actionPerformed(ActionEvent event) {

// TODO Auto-generated method stub

if(event.getSource()==ok)

{

String n = name.getText().trim();

String i = ip.getText().trim();

if("".equals(n)||"".equals(i))

{

JOptionPane.showMessageDialog(null,"昵称、IP不能够为空!","错误",JOptionPane.OK_OPTION);

}

else{login(n,i);}

}

if(event.getSource()==cancle)

{

name.setText("");

ip.setText("");

}

}

}

/**

* 进行登录

* @param name

* @param ip

*/

public void login(String name,String ip)

{

try {

socket = new Socket(ip,7777);

DataOutputStream out = new DataOutputStream(socket.getOutputStream());

out.writeUTF(name);

out.flush();//强制输出缓存中的内容

//out.close();

new ClientFrame(name,socket);

destroywindow();

} catch (UnknownHostException e) {

JOptionPane.showMessageDialog(null,"找不到主机地址(IP错误/网络故障)！","错误",JOptionPane.OK_OPTION);

} catch (IOException e) {

}

}

public void destroywindow()

{

this.dispose();

}

public static void main(String[] args)

{

new LoginFrame();

}

}

==================================================

package server;

import java.awt.Container;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.ArrayList;

import java.util.Date;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

public class ServerFrame extends JFrame{

/**

*

*/

private static final long serialVersionUID = 1L;

private JTextArea allmsg;

private JTextField currnum,totalnum,copyright,chatmsg;

private JButton send;

private JScrollPane js;

int num1,num2,port;/* -- num1:当前在线人数 num2:总上线人数 port:服务端口号 --*/

private ServerSocket ss;

ArrayListuser lists;//存放所有在线用户

public ServerFrame()

{

super("聊天室服务器端");

this.setSize(310,660);

this.setLocation(200,50);

lists = new ArrayListuser();

num1 = num2 =0;

port = 7777;

currnum = new JTextField(" 当前在线人数： "+num1);

currnum.setEnabled(false);

totalnum = new JTextField(" 上线总人数： "+num2);

totalnum.setEnabled(false);

copyright = new JTextField(" ----- all copyright @ TOP-king -----");

copyright.setEnabled(false);

allmsg = new JTextArea();

allmsg.append(" --------------- 系统消息 --------------\n");

allmsg.setEditable(false);

allmsg.setLineWrap(true); //允许自动换行

js = new JScrollPane(allmsg);//为JTextArea添加滚动条

chatmsg = new JTextField("在此输入系统信息");

chatmsg.addActionListener(new ActionListener(){

@SuppressWarnings("deprecation")

public void actionPerformed(ActionEvent arg0) {

String str = chatmsg.getText().trim();

if(!"".equals(str))

{sendmsg((new Date()).toLocaleString()+" -- 系统消息： "+str);chatmsg.setText("");}

else

JOptionPane.showMessageDialog(null, "消息不能为空","错误",JOptionPane.OK_OPTION);

chatmsg.setText("");/* -- 发送信息后java语音聊天源代码，将输入栏中的信息清空 -- */

}

});

send = new JButton("发送");

send.addActionListener(new ActionListener(){

@SuppressWarnings("deprecation")

public void actionPerformed(ActionEvent arg0) {

String str = chatmsg.getText().trim();

if(!"".equals(str))

{sendmsg((new Date()).toLocaleString()+" -- 系统消息： "+str);chatmsg.setText("");}

else

JOptionPane.showMessageDialog(null, "消息不能为空","错误",JOptionPane.OK_OPTION);

chatmsg.setText("");/* -- 发送信息后，将输入栏中的信息清空 -- */

}

});

//建立容器

addcomponettocontainer();

this.addWindowListener(new WindowAdapter(){

public void windowClosing(WindowEvent we)

{

sendmsg("SYSTEM_CLOSED");/* -- 向客户端发送服务器关闭信息 -- */

destory();

}

});

start(); /* -- 启动连接服务 -- */

}

public void addcomponettocontainer()

{

//Container建立容器

Container c = this.getContentPane();

c.setLayout(null);

currnum.setBounds(20,15,130,20);

totalnum.setBounds(155,15,125,20);

js.setBounds(10,50,280,500);

chatmsg.setBounds(10,560,180,30);

send.setBounds(220,560,70,30);

copyright.setBounds(10,600,280,20);

c.add(currnum);

c.add(totalnum);

c.add(js);

c.add(chatmsg);

c.add(send);

c.add(copyright);

this.setVisible(true);

this.setResizable(false);

}

/**

* start()方法监听客户的连接

* 并且保存客户端的相关信息EG：用户昵称、用户所使用的Socket

* 用户连接到服务器成功之后，将其保存到用户列表中，并为该用户启动一个线程用于通信 */

@SuppressWarnings("deprecation")

public void start()

{

boolean isStarted = false;/* -- 用于标记服务器是否已经正常启动 -- */

try {

this.ss = new ServerSocket(port);

isStarted = true;

this.allmsg.append((new Date()).toLocaleString()+" 服务器启动 @ 端口: "+port+"\n");

while(isStarted)

{

Socket client = this.ss.accept(); /* -- 监听客户端的连接 -- */

DataInputStream in = new DataInputStream(client.getInputStream());

String name = in.readUTF();

user u = new user();

u.name = name;

u.socket = client;

lists.add(u); //将该用户加到列表中去

num1++;

num2++;

currnum.setText(" 当前在线人数： "+num1);

totalnum.setText(" 上线总人数： "+num2);

this.allmsg.append((new Date()).toLocaleString()+" : "+u.name+" 登录 \n");

new Thread(new ClientThread(u)).start();/* -- 为该用户启动一个通信线程 -- */

}

} catch (IOException e) {

System.out.println("服务器已经启动......");

System.exit(0);

}

}

/**

* 通信线程主要功能包括：

* 1.监听客户端输入的信息

* 2.将接收到的信息转发给其java语音聊天源代码他用户 */

class ClientThread implements Runnable

{

user user = null;

boolean isConnected = true;

DataInputStream dis = null;

DataOutputStream dos = null;

public ClientThread(user u)

{

this.user = u;

try {

this.dis = new DataInputStream(this.user.socket.getInputStream());

this.dos = new DataOutputStream(this.user.socket.getOutputStream());

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public void run()

{

readmsg();

}

/* -- 读取客户的聊天信息 -- */

@SuppressWarnings("deprecation")

public void readmsg()

{

while(isConnected)

{

try {

String msg = dis.readUTF();

if("quitlogout".equals(msg))//当用户关闭客户端窗口时，发送quit字符串 表示用户已经退出

{

num1--;

try{

this.dis.close();

this.dos.close();

this.user.socket.close();

this.isConnected = false;

}catch(IOException ioe)

{

ioe.printStackTrace();

}finally{

this.isConnected = false;

if(dis!=null) this.dis.close();

if(dos!=null) this.dos.close();

if(this.user.socket!=null) this.user.socket.close();

}

lists.remove(this.user);//从列表中删除该用户

currnum.setText(" 当前在线人数： "+num1);

allmsg.append((new Date()).toLocaleString()+" : "+this.user.name+" 退出\n");

}

else

sendmsg(msg);

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

/* -- 将信息进行转发 -- */

public void sendmsg(String msg)

{

user us = new user();

DataOutputStream os = null;

if(lists.size()0)

{

for(int i=0;ilists.size();i++)

{

us = lists.get(i);

try {

os = new DataOutputStream(us.socket.getOutputStream());

os.writeUTF(msg);

} catch (IOException e) {

e.printStackTrace();

}

}

}

else

JOptionPane.showMessageDialog(null, "当前无用户在线。发送消息失败","失败",JOptionPane.OK_OPTION);

}

public void destory()

{

try {

this.ss.close();

} catch (IOException e) {

e.printStackTrace();

}

this.dispose();

}

public static void main(String[] args)

{

new ServerFrame();

}

}

=================================================

package server;

import java.net.*;

public class user {

String name;

Socket socket;

}

关于java语音聊天源代码和java聊天室代码的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。