谁有java的socket的GUI聊天室程序?
我想学习一下怎么用socket和多线程,如果谁有的话,请给我发一个吧谢谢了jixiaochaoworm@sina.com...
我想学习一下怎么用socket和多线程,如果谁有的话,请给我发一个吧
谢谢了
jixiaochaoworm@sina.com 展开
谢谢了
jixiaochaoworm@sina.com 展开
展开全部
给你个,但是不是很完美(可修改一下),可以完成简单的聊天功能.
源代码://liaotian.java
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;
import java.net.*;
public class liaotian extends JFrame implements ActionListener{
public static void main(String[] args){
liaotian frame=new liaotian();
}
JButton command,command2,command3;
JRadioButton rb[]=new JRadioButton[2];
JTextArea ta1;
JTextField tf1,tf2,tf3;
ServerSocket socket1;
Socket insocket1,socket2;
String inbuf;
BufferedReader in1;
PrintWriter out1;
mt625_server t1;
mt625_client t2;
public liaotian(){
super("聊天");
Container c=getContentPane();
c.setLayout(null);
JLabel lb=new JLabel("TCP通信程序");
lb.setFont(new Font("宋体",Font.BOLD,16));
lb.setForeground(Color.black);
lb.setSize(2000,20);
lb.setLocation(10,2);
c.add(lb);
String str1[]={"服务端","客户端"};
ButtonGroup bg1=new ButtonGroup();
for(int i=0;i<2;i++){
rb[i]=new JRadioButton(str1[i]);
rb[i].setFont(new Font("宋体",Font.BOLD,14));
rb[i].setForeground(Color.black);
rb[i].setSize(80,20);
rb[i].setLocation(10+i*80,27);
c.add(rb[i]);
bg1.add(rb[i]);
}
rb[0].setSelected(true);
JLabel lb1=new JLabel("连接主机IP");
lb1.setFont(new Font("宋体",Font.BOLD,16));
lb1.setForeground(Color.black);
lb1.setSize(120,25);
lb1.setLocation(16,55);
c.add(lb1);
tf1=new JTextField("59.68.255.27");
tf1.setForeground(Color.black);
tf1.setSize(250,25);
tf1.setLocation(120,55);
c.add(tf1);
command=new JButton("连接");
command.setFont(new Font("宋体",Font.BOLD,16));
command.setSize(110,20);
command.setLocation(380,55);
command.addActionListener(this);
c.add(command);
JLabel lb2=new JLabel("接收到信息");
lb2.setFont(new Font("宋体",Font.BOLD,16));
lb2.setForeground(Color.black);
lb2.setSize(120,20);
lb2.setLocation(10,85);
c.add(lb2);
ta1=new JTextArea();
ta1.setForeground(Color.black);
ta1.setSize(250,200);
ta1.setLocation(120,85);
c.add(ta1);
JLabel lb3=new JLabel("发送信息");
lb3.setFont(new Font("宋体",Font.BOLD,16));
lb3.setForeground(Color.black);
lb3.setSize(120,25);
lb3.setLocation(10,300);
c.add(lb3);
tf2=new JTextField();
tf2.setForeground(Color.black);
tf2.setSize(250,25);
tf2.setLocation(120,300);
c.add(tf2);
command2=new JButton("发送信息");
command2.setFont(new Font("宋体",Font.BOLD,16));
command2.setSize(110,25);
command2.setLocation(380,300);
command2.addActionListener(this);
command2.setEnabled(false);
c.add(command2);
JLabel lb4=new JLabel("连接状态: ");
lb4.setFont(new Font("宋体",Font.BOLD,14));
lb4.setForeground(Color.black);
lb4.setSize(120,25);
lb4.setLocation(180,27);
c.add(lb4);
tf3=new JTextField("离线");
tf3.setForeground(Color.black);
tf3.setSize(120,25);
tf3.setLocation(270,27);
c.add(tf3);
command3=new JButton("结束连接");
command3.setFont(new Font("宋体",Font.BOLD,16));
command3.setSize(110,20);
command3.setLocation(380,85);
command3.addActionListener(this);
command3.setEnabled(false);
c.add(command3);
t1=new mt625_server();
t2=new mt625_client();
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500,400);
setVisible(true);
setLocation(300,300);
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==command){
try{
if(rb[0].isSelected()==true){
inbuf="";
tf2.setText("");
t1.start();
}
else{
inbuf="";
tf2.setText("");
t2.start();
}
}
catch (Exception e2) {tf3.setText("发生错误");}
}
if(e.getSource()==command2){
out1.write(tf2.getText()+"\n");
out1.flush();
tf2.setText("");
}
if(e.getSource()==command3){
try{
if(rb[0].isSelected()==true){
insocket1.close();
tf3.setText("离线");
command2.setEnabled(false);
command3.setEnabled(false);
}
else{
socket2.close();
tf3.setText("离线!");
command2.setEnabled(false);
command3.setEnabled(false);
}
}catch (Exception e2) {tf3.setText("发生错误");}
}
}
class mt625_server extends Thread{
public mt625_server(){}
public void run(){
try{
command.setEnabled(false);
tf3.setText("正在等待连接!");
tf1.setText(Inet4Address.getLocalHost().getHostAddress());
socket1=new ServerSocket(21);
insocket1=socket1.accept();
in1=new BufferedReader(new InputStreamReader(insocket1.getInputStream()));
out1=new PrintWriter(insocket1.getOutputStream(),true);
while(true){
if(socket1.isBound()==true){
tf3.setText("正在连接!");
command2.setEnabled(true);
command3.setEnabled(true);
break;
}
}
while(true){
inbuf=in1.readLine();
if(inbuf.length()>0)
{
ta1.append(inbuf);
ta1.append("\n");
}
}
}
catch(Exception e){}
}
}
class mt625_client extends Thread{
public mt625_client(){}
public void run(){
try{
command.setEnabled(false);
tf3.setText("正在等待连接!");
socket2=new Socket();
socket2.connect(new InetSocketAddress(tf1.getText(),21),5000);
in1=new BufferedReader(new InputStreamReader(socket2.getInputStream()));
out1=new PrintWriter(socket2.getOutputStream(),true);
while(true){
if(socket2.isConnected()==true){
tf3.setText("正在连接!");
command2.setEnabled(true);
command3.setEnabled(true);
break;
}
}
inbuf="";
while(true){
inbuf=in1.readLine();
if(inbuf.length()>0)
{
ta1.append(inbuf);
ta1.append("\n");
}
}
}
catch(Exception e){}
}
}
}
源代码://liaotian.java
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;
import java.net.*;
public class liaotian extends JFrame implements ActionListener{
public static void main(String[] args){
liaotian frame=new liaotian();
}
JButton command,command2,command3;
JRadioButton rb[]=new JRadioButton[2];
JTextArea ta1;
JTextField tf1,tf2,tf3;
ServerSocket socket1;
Socket insocket1,socket2;
String inbuf;
BufferedReader in1;
PrintWriter out1;
mt625_server t1;
mt625_client t2;
public liaotian(){
super("聊天");
Container c=getContentPane();
c.setLayout(null);
JLabel lb=new JLabel("TCP通信程序");
lb.setFont(new Font("宋体",Font.BOLD,16));
lb.setForeground(Color.black);
lb.setSize(2000,20);
lb.setLocation(10,2);
c.add(lb);
String str1[]={"服务端","客户端"};
ButtonGroup bg1=new ButtonGroup();
for(int i=0;i<2;i++){
rb[i]=new JRadioButton(str1[i]);
rb[i].setFont(new Font("宋体",Font.BOLD,14));
rb[i].setForeground(Color.black);
rb[i].setSize(80,20);
rb[i].setLocation(10+i*80,27);
c.add(rb[i]);
bg1.add(rb[i]);
}
rb[0].setSelected(true);
JLabel lb1=new JLabel("连接主机IP");
lb1.setFont(new Font("宋体",Font.BOLD,16));
lb1.setForeground(Color.black);
lb1.setSize(120,25);
lb1.setLocation(16,55);
c.add(lb1);
tf1=new JTextField("59.68.255.27");
tf1.setForeground(Color.black);
tf1.setSize(250,25);
tf1.setLocation(120,55);
c.add(tf1);
command=new JButton("连接");
command.setFont(new Font("宋体",Font.BOLD,16));
command.setSize(110,20);
command.setLocation(380,55);
command.addActionListener(this);
c.add(command);
JLabel lb2=new JLabel("接收到信息");
lb2.setFont(new Font("宋体",Font.BOLD,16));
lb2.setForeground(Color.black);
lb2.setSize(120,20);
lb2.setLocation(10,85);
c.add(lb2);
ta1=new JTextArea();
ta1.setForeground(Color.black);
ta1.setSize(250,200);
ta1.setLocation(120,85);
c.add(ta1);
JLabel lb3=new JLabel("发送信息");
lb3.setFont(new Font("宋体",Font.BOLD,16));
lb3.setForeground(Color.black);
lb3.setSize(120,25);
lb3.setLocation(10,300);
c.add(lb3);
tf2=new JTextField();
tf2.setForeground(Color.black);
tf2.setSize(250,25);
tf2.setLocation(120,300);
c.add(tf2);
command2=new JButton("发送信息");
command2.setFont(new Font("宋体",Font.BOLD,16));
command2.setSize(110,25);
command2.setLocation(380,300);
command2.addActionListener(this);
command2.setEnabled(false);
c.add(command2);
JLabel lb4=new JLabel("连接状态: ");
lb4.setFont(new Font("宋体",Font.BOLD,14));
lb4.setForeground(Color.black);
lb4.setSize(120,25);
lb4.setLocation(180,27);
c.add(lb4);
tf3=new JTextField("离线");
tf3.setForeground(Color.black);
tf3.setSize(120,25);
tf3.setLocation(270,27);
c.add(tf3);
command3=new JButton("结束连接");
command3.setFont(new Font("宋体",Font.BOLD,16));
command3.setSize(110,20);
command3.setLocation(380,85);
command3.addActionListener(this);
command3.setEnabled(false);
c.add(command3);
t1=new mt625_server();
t2=new mt625_client();
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500,400);
setVisible(true);
setLocation(300,300);
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==command){
try{
if(rb[0].isSelected()==true){
inbuf="";
tf2.setText("");
t1.start();
}
else{
inbuf="";
tf2.setText("");
t2.start();
}
}
catch (Exception e2) {tf3.setText("发生错误");}
}
if(e.getSource()==command2){
out1.write(tf2.getText()+"\n");
out1.flush();
tf2.setText("");
}
if(e.getSource()==command3){
try{
if(rb[0].isSelected()==true){
insocket1.close();
tf3.setText("离线");
command2.setEnabled(false);
command3.setEnabled(false);
}
else{
socket2.close();
tf3.setText("离线!");
command2.setEnabled(false);
command3.setEnabled(false);
}
}catch (Exception e2) {tf3.setText("发生错误");}
}
}
class mt625_server extends Thread{
public mt625_server(){}
public void run(){
try{
command.setEnabled(false);
tf3.setText("正在等待连接!");
tf1.setText(Inet4Address.getLocalHost().getHostAddress());
socket1=new ServerSocket(21);
insocket1=socket1.accept();
in1=new BufferedReader(new InputStreamReader(insocket1.getInputStream()));
out1=new PrintWriter(insocket1.getOutputStream(),true);
while(true){
if(socket1.isBound()==true){
tf3.setText("正在连接!");
command2.setEnabled(true);
command3.setEnabled(true);
break;
}
}
while(true){
inbuf=in1.readLine();
if(inbuf.length()>0)
{
ta1.append(inbuf);
ta1.append("\n");
}
}
}
catch(Exception e){}
}
}
class mt625_client extends Thread{
public mt625_client(){}
public void run(){
try{
command.setEnabled(false);
tf3.setText("正在等待连接!");
socket2=new Socket();
socket2.connect(new InetSocketAddress(tf1.getText(),21),5000);
in1=new BufferedReader(new InputStreamReader(socket2.getInputStream()));
out1=new PrintWriter(socket2.getOutputStream(),true);
while(true){
if(socket2.isConnected()==true){
tf3.setText("正在连接!");
command2.setEnabled(true);
command3.setEnabled(true);
break;
}
}
inbuf="";
while(true){
inbuf=in1.readLine();
if(inbuf.length()>0)
{
ta1.append(inbuf);
ta1.append("\n");
}
}
}
catch(Exception e){}
}
}
}
展开全部
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询