java多线程聊天代码 java多线程示例代码
Java做一个多线程类似于QQ的聊天程序。
//时间关系,粗略的做了一下,一个模拟UDP协议的测试,图标,IP,以及端口都可以设成
公司主营业务：成都网站设计、成都做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联推出罗山免费做网站回馈大家。
//发送者端的电脑参数!
import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.GridLayout;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.io.IOException;
import java.io.Serializable;
import java点虐 .DatagramPacket;
import java点虐 .DatagramSocket;
import java点虐 .InetAddress;
import java点虐 .SocketException;
import java点虐 .UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
public class Day03_A extends JFrame implements Serializable {
private static final long serialVersionUID = 57L;
private JTextArea txtRece, txtSend;// 接受与发送文本域!
private JPanel jp1, jp2;// 面板!
private JScrollPane jsp;
private JLabel jab;// 标签
private JButton jb;// 按钮
private JMenuBar jmb;// 窗体状态栏
private JMenuItem a=null,b=null;
private DatagramSocket dsend = null, drece;
private DatagramPacket dp1, dp2;
private byte[] by1, by2;
private String[][][] menArr= {{{"语言"},{"中文","英文"}}, {{"字体"},{"隶书","彩云",}},{{"辅助"},{"放大","缩小"}}, {{"功能"},{"计算","闹钟"}}};
Day03_A() {
by2 = new byte[1024];
this.setTitle("山寨QQ测试");// 窗体标题
this.setBounds(300, 300, 400, 500);// 位置及大小!
this.setResizable(false);
this.setIconImage(new ImageIcon("E:/Java_Worker/Day_41学习_Gui/src/com/djw/swing01/qq.png").getImage());
this.setLayout(new GridLayout(2, 1));// 网格模式2行1列
init();
this.setJMenuBar(jmb);
this.setVisible(true);
}
private void init() {
jmb = new JMenuBar();
for(int i=0;imenArr.length;i++) {
for(int j=0;jmenArr[i].length;j++) {
for(int x=0;xmenArr[i][j].length;x++) {
if(j==0) {
a=new JMenu(menArr[i][j][x]);
}else {
b=new JMenuItem(menArr[i][j][x]);
a.add(b);
}
}
jmb.add(a);
}
}
jp1 = new JPanel();
jp1.setLayout(new BorderLayout());
txtRece = new JTextArea();
jsp = new JScrollPane(txtRece);
jsp.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
this.add(jsp);
jp2 = new JPanel();// 面板
jp2.setBackground(new Color(107, 197, 127));
jp2.setLayout(new BorderLayout());
txtSend = new JTextArea();
jab = new JLabel();
jab.setText("[ALT+S]/[回车+CTRL]或者[点击发送按钮]:发送信息");
jab.setHorizontalAlignment(JLabel.CENTER);// 标签文本居中
jb = new JButton("发送");
jp2.add(jab, BorderLayout.NORTH);// 指定到面板北面
jp2.add(txtSend, BorderLayout.CENTER);// 文本放中间
jp2.add(jb, BorderLayout.SOUTH);
this.add(jp2);
myeve();
}
private void myeve() {
this.setDefaultCloseOperation(EXIT_ON_CLOSE);// 窗体可关闭
try {
dsend = new DatagramSocket();// 发送端套接字
drece = new DatagramSocket(10008);
} catch (SocketException e) {
e.printStackTrace();
}
re();// 启动无限循环侦听!
txtSend.addKeyListener(new KeyAdapter() {
public void keyPressed(KeyEvent k) {
if (k.isControlDown() k.getKeyCode() == KeyEvent.VK_ENTER) {
se();
}
if (k.isAltDown() k.getKeyCode() == KeyEvent.VK_S) {
se();
}
}
});
jb.addMouseListener(new MouseAdapter() {
public void mouseClicked(MouseEvent arg0) {
se();
txtSend.requestFocus();
}
});
}
private void se() {
try {
by1 = txtSend.getText().getBytes();
dp1 = new DatagramPacket(by1, by1.length, InetAddress.getByName("192.168.2.4"), 10008);
dsend.send(dp1);// 推送数据
txtSend.setText(null);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
private void re() {
new Thread() {
public void run() {
while (true) {
try {
String time = new SimpleDateFormat("MM-dd/HH:mm").format(new Date());
dp2 = new DatagramPacket(by2, by2.length);
drece.receive(dp2);
String ip = dp2.getAddress().getHostAddress();
txtRece.append("用户IP:" + ip + " 时间:");
txtRece.append(time + ": " + System.getProperty("line.separator"));
txtRece.append(new String(by2, 0, dp2.getLength()) + System.getProperty("line.separator"));
txtRece.setCaretPosition(txtRece.getText().length());
} catch (IOException e) {
e.printStackTrace();
}
}
}
}.start();
}
public static void main(String[] args) {
new Day03_A();
}
}
关于用java多线程做的一个多人聊天小程序的一个问题——如何实现进程间的通信？
传统的进程间通信的方式有大致如下几种：
(1) 管道(PIPE)
(2) 命名管道(FIFO)
(3) 信号量(Semphore)
(4) 消息队列(MessageQueue)
(5) 共享内存(SharedMemory)
(6) Socket
Java如何支持进程间通信。我们把Java进程理解为JVM进程。很明显，传统的这些大部分技术是无法被我们的应用程序利用了（这些进程间通信都是靠系统调用来实现的）。但是Java也有很多方法可以进行进程间通信的。
除了上面提到的Socket之外，当然首选的IPC可以使用Rmi，或者Corba也可以。另外Java nio的MappedByteBuffer也可以通过内存映射文件来实现进程间通信(共享内存)。
java 多线程 聊天 别拿网上的程序糊弄我 ！！
这个是我们练习是做的，下面的分别为两个客户端，写的有点固定，你可以自行的在修改一下
1.
package com.yl.testqq;
import java.awt.Color;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java点虐 .ServerSocket;
import java点虐 .Socket;
import java点虐 .UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JTextArea;
import javax.swing.border.BevelBorder;
public class Zjh extends JFrame implements Runnable {
private final JTextArea txtRes;
private final JTextArea txtSend;
private Socket client;
private static final String IP = "localhost";
private PrintStream ps;
public static final int PORT = 6666;
private ServerSocket server;
private BufferedReader br;
/**
* Launch the application
* @param args
*/
public static void main(String args[]) {
EventQueue.invokeLater(new Runnable() {
public void run() {
try {
Zjh frame = new Zjh();
frame.setVisible(true);
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
/**
* Create the frame
*/
public Zjh() {
super();
setBackground(new Color(0, 0, 0));
setTitle("Cxr to Zjh");
getContentPane().setBackground(new Color(0, 0, 0));
getContentPane().setLayout(null);
setBounds(100, 100, 300, 350);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
txtRes = new JTextArea();
txtRes.setBorder(new BevelBorder(BevelBorder.LOWERED));
txtRes.setLineWrap(true);
txtRes.setBackground(new Color(255, 255, 255));
txtRes.setEditable(false);
txtRes.setBounds(10, 10, 270, 150);
getContentPane().add(txtRes);
txtSend = new JTextArea();
txtSend.setBorder(new BevelBorder(BevelBorder.LOWERED));
txtSend.addKeyListener(new KeyAdapter() {
public void keyPressed(final KeyEvent ke) {
if(ke.getKeyCode()==KeyEvent.VK_ENTER ke.isControlDown()){
sendMess();
}
}
});
txtSend.setLineWrap(true);
txtSend.setBackground(new Color(255, 255, 255));
txtSend.setBounds(10, 166, 270, 115);
getContentPane().add(txtSend);
final JButton btnSend = new JButton();
btnSend.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent arg0) {
sendMess();
}
});
btnSend.setText("发送...");
btnSend.setBounds(184, 287, 84, 28);
getContentPane().add(btnSend);
//
new Thread(this).start();
}
private void sendMess(){
try {
client = new Socket(Zjh.IP,Cxr.PORT);
ps = new PrintStream(client.getOutputStream());
ps.println(txtSend.getText());
txtSend.setText("");
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
try {
server = new ServerSocket(Zjh.PORT);
while(true){
client = server.accept();
br = new BufferedReader(new InputStreamReader(client.getInputStream()));
txtRes.insert("Cxr say:"+br.readLine()+"\r\n", 0);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
2.
package com.yl.testqq;
import java.awt.Color;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java点虐 .ServerSocket;
import java点虐 .Socket;
import java点虐 .UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.border.BevelBorder;
public class Cxr extends JFrame implements Runnable {
private final JTextArea txtRes;
private final JTextArea txtSend;
public static final int PORT = 5555;
private ServerSocket server;
private BufferedReader br;
private static final String IP = "localhost";
private PrintStream ps;
private Socket client;
// private Socket client;
/**
* Launch the application
* @param args
*/
public static void main(String args[]) {
EventQueue.invokeLater(new Runnable() {
public void run() {
try {
Cxr frame = new Cxr();
frame.setVisible(true);
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
/**
* Create the frame
*/
public Cxr() {
super();
setTitle("Zjh to Cxr");
getContentPane().setBackground(new Color(176, 224, 230));
getContentPane().setLayout(null);
setBounds(100, 100, 300, 350);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
txtRes = new JTextArea();
txtRes.setBorder(new BevelBorder(BevelBorder.LOWERED));
txtRes.setLineWrap(true);
txtRes.setBackground(new Color(255, 245, 238));
txtRes.setEditable(false);
txtRes.setBounds(10, 10, 270, 150);
getContentPane().add(txtRes);
txtSend = new JTextArea();
txtSend.setBorder(new BevelBorder(BevelBorder.LOWERED));
txtSend.addKeyListener(new KeyAdapter() {
public void keyPressed(final KeyEvent ke) {
if(ke.getKeyCode()==KeyEvent.VK_ENTER ke.isControlDown()){
sendMess();
}
}
});
txtSend.setLineWrap(true);
txtSend.setBackground(new Color(255, 245, 238));
txtSend.setBounds(10, 166, 270, 115);
getContentPane().add(txtSend);
final JButton btnSend = new JButton();
btnSend.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent arg0) {
sendMess();
}
});
btnSend.setText("发送...");
btnSend.setBounds(205, 287, 75, 28);
getContentPane().add(btnSend);
// final JButton button = new JButton();
// button.addActionListener(new ActionListener() {
// public void actionPerformed(final ActionEvent arg0) {
// txtSend.setForeground(Color.RED);
// txtRes.setForeground(Color.RED);
// }
// });
// button.setText("红字体");
// button.setBounds(20, 287, 106, 28);
// getContentPane().add(button);
//
new Thread(this).start();
}
private void sendMess(){
try {
client = new Socket(Cxr.IP,Zjh.PORT);
ps = new PrintStream(client.getOutputStream());
ps.println(txtSend.getText());
txtSend.setText("");
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
try {
server = new ServerSocket(Cxr.PORT);
while (true){
client = server.accept();
br = new BufferedReader(new InputStreamReader(client.getInputStream()));
txtRes.insert("Zjh say:"+br.readLine()+"\r\n", txtRes.getRows());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
求socket有返回有发送的多线程java示例代码
服务端
package test;
import java点虐 .*;
import java.io.*;
public class Server {
private ServerSocket ss;
private Socket socket;
private BufferedReader in;
private PrintWriter out;
public Server() {
try {
ss = new ServerSocket(10000);
socket = ss.accept();
int i=0;
while (true) {
i++;
System.out.println("server "+i);
String RemoteIP = socket.getInetAddress().getHostAddress();
String RemotePort = ":" + socket.getLocalPort();
System.out.println("+A client come in!IP:" + RemoteIP
+ RemotePort);
in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
String line = in.readLine();
System.out.println("++Cleint send is :" + line);
out = new PrintWriter(socket.getOutputStream(), true);
out.println("+++Your Message Received!");
// out.close();
// in.close();
// socket.close();
}
} catch (IOException e) {
out.println("++++wrong");
}
System.out.println("服务端不会结束");
}
public static void main(String[] args) {
new Server();
}
};
客户端
package test;
import java.io.*;
import java点虐 .*;
public class Client {
Socket socket;
BufferedReader in;
PrintWriter out;
public Client() {
try {
System.out.println("-Try to Connect to 127.0.0.1:10000");
socket = new Socket("127.0.0.1", 10000);
System.out.println("--The Server Connected!");
System.out.println("---Please enter some Character:");
BufferedReader line;
int i=0;
while(true){
i++;
System.out.println("client "+i);
line = new BufferedReader(new InputStreamReader(
System.in));
out = new PrintWriter(socket.getOutputStream(), true);
out.println(line.readLine());
in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
System.out.println("----"+in.readLine());
// out.close();
// in.close();
// socket.close();
}
} catch (IOException e) {
out.println("-----Wrong");
}
System.out.println("客户端不会结束");
}
public static void main(String[] args) {
new Client();
}
};
网站栏目：java多线程聊天代码 java多线程示例代码
文章分享：http://mswzjz.cn/article/ddsihoi.html