java的Socket 连接

package chartall;

import java.awt.*;

import java.awt.event.*;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.Socket;

import java.net.UnknownHostException;

import javax.swing.*;

import java.sql.*;

import java.util.*;

public class cilent extends JFrame {

private JButton send;//添加发送按钮

private JPanel up;//添加内容为up的面板

private JPanel center;//添加内容为center的面板

private JPanel down;//添加内容为down的面板

private JTextArea inputTextArea;//输入

private JTextArea showTextArea;//显示

private JComboBox userlist;//输入

private JButton serverjoin;//添加按钮serverjoin

private JButton serverjoinsubmit=new JButton("确定");;//将上面的按钮自定义为确定

private JLabel serverjoinlable;//添加内容为serverjoinlable

private JTextField username;//添加用户名文本框

private JTextField ip;//添加ip地址文本框

private JTextField port;//添加端口文本框

private Socket client;//定义client包

private String userid;//用户账号

private InetAddress ips;

private int ports;//端口

cilent(){

gui();//图形界面

listion();//按钮监听

flashuser();//刷新在线人数

}

void gui(){

//窗体

JFrame f=new JFrame("客户端");

f.setSize(800,500);// 设置行高800

f.setLocation(300,100); // 设置每页显示的数目300

up=new JPanel() ;

center=new JPanel() ;

down=new JPanel() ;

inputTextArea=new JTextArea(5,50);//输入文本框大小

showTextArea=new JTextArea(20,50);//显示文本框大小

showTextArea.setEditable(false);

serverjoinlable=new JLabel("未连接服务器") ;

down.add(serverjoinlable);

send=new JButton("发送") ;//按钮名为发送

serverjoin=new JButton("连接服务器") ;

down.add(serverjoin);

userlist=new JComboBox();

userlist.addItem("所有人");

up.add(new JScrollPane(showTextArea));

center.add(inputTextArea);

down.add(userlist);

down.add(send);

f.setLayout(new BorderLayout());

f.add(up,BorderLayout.NORTH);//按钮添加到面板

f.add(center,BorderLayout.CENTER);//按钮添加到面板

f.add(down,BorderLayout.SOUTH);//按钮添加到面板

f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

f.setVisible(true);//设为可视

showTextArea.setForeground(new Color(255,177,88));

}

//清屏

//连接服务器监听

void listion() {

//连接服务器监听

serverjoin.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e) {

JDialog dialog = new JDialog(cilent.this, true );//设置模态对话框

dialog.setLayout(new GridLayout(4,2));//设置布局及参数

dialog.setTitle("服务器连接");

dialog.setSize(300, 200);

dialog.setLocation(50, 50);

JLabel usernametext=new JLabel("用户名");//设置标签

JLabel iptext=new JLabel("IP");//设置标签

JLabel porttext=new JLabel("端口");//设置标签

username=new JTextField();//设置对话栏

ip=new JTextField();//设置对话栏

port=new JTextField();//设置对话栏

dialog.add(usernametext);//组件加入对话框

dialog.add(username);//组件加入对话框

dialog.add(iptext);//组件加入对话框v

dialog.add(ip);//组件加入对话框

dialog.add(porttext);//组件加入对话框

dialog.add(port);//组件加入对话框

dialog.add(serverjoinsubmit);//组件加入对话框

dialog.setVisible(true);//窗体可见

});

//服务器连接输入ip端口并提交

serverjoinsubmit.addActionListener(new ActionListener() { //监听器

public void actionPerformed(ActionEvent e) {

serverjoinlable.setText("已连接服务器");

try {

ips = InetAddress.getByName(ip.getText());

ports=Integer.parseInt(port.getText());

client=new Socket(ips,ports);

//面板 弹出对话框

JOptionPane.showMessageDialog(null, "服务器连接成功！！！！！！", "information", JOptionPane.INFORMATION_MESSAGE);

PrintWriter writer = new PrintWriter(client.getOutputStream());//创建对象

userid=username.getText();//获取username给变量userid

String a=userid+"@@"+"reg";

writer.println(a);

writer.flush();

} catch (Exception e1) {

e1.printStackTrace();

}

}

});

//发送聊天内容

send.addActionListener(new ActionListener() { //创建对象

public void actionPerformed(ActionEvent e) {

try {

PrintWriter writer = new PrintWriter(client.getOutputStream());//创建对象

String a=userid+"@"+inputTextArea.getText()+"@"+userlist.getSelectedItem();

writer.println(a);

writer.flush();

//面板 弹出一个对话框

JOptionPane.showMessageDialog(null, "数据发送成功！！！", "information", JOptionPane.INFORMATION_MESSAGE);

//弹出消息

} catch (Exception e1) {

e1.printStackTrace();

}

}

});

}

//刷新按钮监听

void flashuser(){

new Thread() {//多线程方法

public void run() {//多线程run方法

while(true) { //while死循环

System.out.println(client);

if(client!=null) {//判断是否为空

try {

BufferedReader r = new BufferedReader(new InputStreamReader(client.getInputStream())); //用inputstreamreader中介把system.in字节流换成字符流bufferedreader

String line=r.readLine();

String[] arr=line.split("@");//用@隔开

//null@aaaa@userlist

if(arr[arr.length-1].equals("userlist")) {//判断其末位长度-1是否等于userlist

for(String user:arr) {

if(!user.equals("null")&&!user.equals("userlist")) {

userlist.addItem(user);

}

}

}else if(arr[arr.length-1].equals("群发聊天")) {

showTextArea.append(arr[0]+arr[1]+"\n");

}else {

showTextArea.append(arr[0]+arr[1]+arr[2]+"\n");

}

}catch(Exception e) {

e.printStackTrace();

}

}

}

}

}.start();

}

//先运行主函数

public static void main(String[] args) {

new cilent();

}