【ClientSocketDemo.java 客戶端Java源代碼】
成都創(chuàng)新互聯(lián)主要從事成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)新?lián)?10年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):18982081108
import java.net.*;
import java.io.*;
public class ClientSocketDemo
{
//聲明客戶端Socket對(duì)象socket
Socket socket = null;
//聲明客戶器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明字符串?dāng)?shù)組對(duì)象response，用于存儲(chǔ)從服務(wù)器接收到的信息
String response[];
//執(zhí)行過程中，沒有參數(shù)時(shí)的構(gòu)造方法，本地服務(wù)器在本地，取默認(rèn)端口10745
public ClientSocketDemo()
{
try
{
//創(chuàng)建客戶端socket，服務(wù)器地址取本地，端口號(hào)為10745
socket = new Socket("localhost",10745);
//創(chuàng)建客戶端數(shù)據(jù)輸入輸出流，用于對(duì)服務(wù)器端發(fā)送或接收數(shù)據(jù)
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
//獲取客戶端地址及端口號(hào)
String ip = String.valueOf(socket.getLocalAddress());
String port = String.valueOf(socket.getLocalPort());
//向服務(wù)器發(fā)送數(shù)據(jù)
out.writeUTF("Hello Server.This connection is from client.");
out.writeUTF(ip);
out.writeUTF(port);
//從服務(wù)器接收數(shù)據(jù)
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();}
}
//執(zhí)行過程中，有一個(gè)參數(shù)時(shí)的構(gòu)造方法，參數(shù)指定服務(wù)器地址，取默認(rèn)端口10745
public ClientSocketDemo(String hostname)
{
try
{
//創(chuàng)建客戶端socket，hostname參數(shù)指定服務(wù)器地址，端口號(hào)為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();}
}
//執(zhí)行過程中，有兩個(gè)個(gè)參數(shù)時(shí)的構(gòu)造方法，第一個(gè)參數(shù)hostname指定服務(wù)器地址
//第一個(gè)參數(shù)serverPort指定服務(wù)器端口號(hào)
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 服務(wù)器端Java源代碼】
import java.net.*;
import java.io.*;
public class ServerSocketDemo
{
//聲明ServerSocket類對(duì)象
ServerSocket serverSocket;
//聲明并初始化服務(wù)器端監(jiān)聽端口號(hào)常量
public static final int PORT = 10745;
//聲明服務(wù)器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明InetAddress類對(duì)象ip，用于獲取服務(wù)器地址及端口號(hào)等信息
InetAddress ip = null;
//聲明字符串?dāng)?shù)組對(duì)象request，用于存儲(chǔ)從客戶端發(fā)送來的信息
String request[];
public ServerSocketDemo()
{
request = new String[3]; //初始化字符串?dāng)?shù)組
try
{
//獲取本地服務(wù)器地址信息
ip = InetAddress.getLocalHost();
//以PORT為服務(wù)端口號(hào)，創(chuàng)建serverSocket對(duì)象以監(jiān)聽該端口上的連接
serverSocket = new ServerSocket(PORT);
//創(chuàng)建Socket類的對(duì)象socket，用于保存連接到服務(wù)器的客戶端socket對(duì)象
Socket socket = serverSocket.accept();
System.out.println("This is server:"+String.valueOf(ip)+PORT);
//創(chuàng)建服務(wù)器端數(shù)據(jù)輸入輸出流，用于對(duì)客戶端接收或發(fā)送數(shù)據(jù)
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
//接收客戶端發(fā)送來的數(shù)據(jù)信息，并顯示
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]);
//向客戶端發(fā)送數(shù)據(jù)
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();
}
}
import java.io.*;
import java.net.*;
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;//引入包。
public class ChatClient {
public static void main(String[] args) {
ChatClient cc = new ChatClient();
cc.receive();
}
JTextField jtf; // 文本條
JTextArea jta; //文本域。
Socket s; //客戶端
PrintWriter out; //輸出流
BufferedReader in; //輸入流
public ChatClient() {
JFrame frame = new JFrame("ChatClient");//窗口
frame.setSize(400, 300); //大小
jta = new JTextArea(); //文本域
jta.setEditable(false); //不可編輯
jtf = new JTextField();//文件條
jtf.addActionListener(new ActionListener() { //添加監(jiān)聽。
public void actionPerformed(ActionEvent arg0) {
send(); //調(diào)用send（）方法
}
});
frame.getContentPane().add(new JScrollPane(jta)); //添加滾動(dòng)條
frame.getContentPane().add(jtf, "South"); //添加文本條
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); //關(guān)閉窗口。
frame.setVisible(true); //可顯示的。
try {
s = new Socket("127.0.0.1", 9000); //連接服務(wù)端 socket("主機(jī)名"，端口號(hào));
in = new BufferedReader(new InputStreamReader(s.getInputStream())); //建立輸入流
out = new PrintWriter(s.getOutputStream());//輸出流
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void receive() { //接受服務(wù)端發(fā)來別的客戶端的信息。
while (true) {
try {
String text = in.readLine(); //讀一行
this.jta.append(text + "\n"); //jta 添加上讀入的。
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return;
}
}
}
public void send() { //發(fā)送消息
String text = this.jtf.getText(); //得到你輸入的消息
this.jtf.setText(""); //在文本域中顯示你輸入的消息。
out.println(text); //打印出。
out.flush(); //清空
}
}
Server端
import java.net.*;
import java.io.*;
import java.util.*;//引入包
public class ChatServer {
public static void main(String[] args) throws Exception {
ServerSocket ss = new ServerSocket(9000); //建立服務(wù)端，端口號(hào)為9000
List list = new ArrayList(); //創(chuàng)建個(gè)List集合。
while (true) {
Socket s = ss.accept(); //等待客戶端的請(qǐng)求。
list.add(s); //把每一個(gè)client都add到集合中去。
Thread t = new ServerThread(s, list); //線程。
t.start(); //啟動(dòng)。
}
}
}
class ServerThread extends Thread {
Socket s;
List list;
BufferedReader in;
PrintWriter out;
public ServerThread(Socket s, List list) { //構(gòu)造。傳入socket和list。
this.s = s;
this.list = list;
try {
in = new BufferedReader(new InputStreamReader(s.getInputStream())); //輸入流
out = new PrintWriter(s.getOutputStream()); //輸出流
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run() { //必須實(shí)現(xiàn)其run（）方法。
while (true) {
try {
String str = in.readLine(); //得到client端的message。
if (str == null) //如果沒有消息就返回。
return;
Iterator it = list.iterator(); //遍歷list。
while (it.hasNext()) { //如果list有下一個(gè)
Socket socket = (Socket) (it.next()); //因?yàn)閘ist中都是存的socket
PrintWriter o = new PrintWriter(socket.getOutputStream()); //輸出流
o.println(str); //輸出
o.flush(); //清空
}
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
return;
}
}
}
}
btnEquals.addActionListener(new MyMonitor(this)); //這里傳的this 是怎么區(qū)分傳進(jìn)來的是 num1 還是 num2 ？
這兒并不需要區(qū)分是num1還是num2, 在下面的處理函數(shù)actionPerformed之中，將num1和num2的值都取出來了的。
public void actionPerformed(ActionEvent e) {
int n1 = Integer.parseInt(tf.num1.getText()); //取num1的值
int n2 = Integer.parseInt(tf.num2.getText()); //取num2的值
tf.num3.setText("" + (n1 + n2));
}
服務(wù)端 用戶名 y 密碼 1 客戶端代碼在我的評(píng)論里，這敲不了那么多字，沒辦法。
登陸實(shí)現(xiàn)類：class Login
package com.server;
import java.awt.Color;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;
public class Login {
boolean f=false;//按登錄時(shí)設(shè)置的一個(gè)標(biāo)志
private JFrame frame = new JFrame("Welcome To MLDN") ;
//設(shè)置窗體
private JButton submit = new JButton("登陸");//設(shè)置登錄按鈕
private JButton reset = new JButton("重置");//設(shè)置重置按鈕
private JLabel nameLab = new JLabel("服務(wù)器：") ;//標(biāo)簽實(shí)例化
private JLabel passLab = new JLabel("密 碼："); //標(biāo)簽實(shí)例化
private JLabel infoLab = new JLabel("服務(wù)器登陸系統(tǒng)"); //標(biāo)簽實(shí)例化
private JTextField nameText = new JTextField(10);//單行文本輸入條
private JPasswordField passText = new JPasswordField() ;//單行密碼文本輸入條
public Login(){//登錄窗口構(gòu)造方法
Font fnt = new Font("Serief",Font.ITALIC + Font.BOLD,12); //設(shè)置字體
infoLab.setFont(fnt) ; // 設(shè)置標(biāo)簽的顯示文字
submit.addActionListener(new ActionListener(){ //采用內(nèi)部匿名類
public void actionPerformed(ActionEvent e){
if(e.getSource()==submit){ //判斷觸發(fā)器源是否是提交按鈕
String tname = nameText.getText() ; //得到輸入的用戶名
String tpass = new String(passText.getPassword()) ;//得到輸入的密碼,此時(shí)通過getPassageword()方法返回的是字符數(shù)組
LoginCheck log = new LoginCheck(tname,tpass) ;//實(shí)例化LoginCheck對(duì)象,傳入輸入的用戶名和密碼
if(log.validate()){//對(duì)用戶名和密碼進(jìn)行驗(yàn)證
try{ //線程異常處理try
Thread.sleep(2000); //2秒后打開聊天窗口
f=true; //登錄成功后的表示項(xiàng)為true
frame.dispose(); //關(guān)閉本窗口
}catch(Exception e1){//異常獲取
e1.printStackTrace();
}
}else{
infoLab.setText("登陸失敗，錯(cuò)誤的用戶名或密碼！") ;//登錄失敗
}
}
}
});
reset.addActionListener(new ActionListener(){ //采用內(nèi)部匿名類
public void actionPerformed(ActionEvent e){
if(e.getSource()==reset){ //判斷觸發(fā)器源是否是提交按鈕
nameText.setText(""); //設(shè)置文本框中的內(nèi)容
passText.setText(""); //設(shè)置文本框中的內(nèi)容
infoLab.setText("服務(wù)器登陸系統(tǒng)"); //恢復(fù)標(biāo)簽顯示
}
}
});
frame.addWindowListener(new WindowAdapter(){//加入窗口監(jiān)聽
public void windowClosing(WindowEvent e){ }
}); // 加入事件
frame.setLayout(null); //使用絕對(duì)定位
nameLab.setBounds(5,5,60,20); //設(shè)置標(biāo)簽的位置及大小
passLab.setBounds(5,30,60,20); //設(shè)置標(biāo)簽的位置及大小
infoLab.setBounds(5,65,220,30); //設(shè)置標(biāo)簽的位置及大小
nameText.setBounds(65,5,100,20); //設(shè)置文本域的位置及大小
passText.setBounds(65,30,100,20); //設(shè)置密碼域的位置及大小
submit.setBounds(165,5,60,20); //設(shè)置按鈕的位置及大小
reset.setBounds(165,30,60,20); //設(shè)置按鈕的位置及大小
frame.add(nameLab); //向窗體加入標(biāo)簽
frame.add(passLab); //向窗體加入標(biāo)簽
frame.add(infoLab); //向窗體加入標(biāo)簽
frame.add(nameText); //向窗體加入文本框
frame.add(passText); //向窗體加入密碼框
frame.add(submit); //向窗體加入按鈕
frame.add(reset) ;//向窗體加入按鈕
frame.setSize(280,130); //設(shè)置窗體大小
frame.getContentPane().setBackground(Color.green) ;//設(shè)置窗體的背景顏色
frame.setLocation(300,200) ;//設(shè)置窗體在電腦桌面上的位置
frame.setVisible(true); //顯示窗口
while(f==false){ //當(dāng)?shù)卿浭r(shí),一直循環(huán)運(yùn)行,
}
new MyServer();//顯示窗體頁面
}
}
驗(yàn)證登陸實(shí)現(xiàn)類 class LoginCheck
package com.server;
public class LoginCheck {
private String name ;//用戶名
private String password ;//密碼
//構(gòu)造方法
public LoginCheck(String name,String password){
this.name = name ;//傳遞用戶名
this.password = password ;//傳遞密碼
}
//驗(yàn)證用戶名和密碼
public boolean validate(){
//驗(yàn)證方法
if("y".equals(name)"1".equals(password)){ //判斷用戶名和密碼是否正確
return true; //返回true
}else{
return false ;//返回false
}
}
}
package com.server;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.DateFormat;
import java.util.Date;
import javax.swing.*;
聊天實(shí)現(xiàn)類 class MyServer
public class MyServer {
protected JLabel lab10;
// 全體變量,做傳遞的一個(gè)組件
String s = "已經(jīng)成功連接";
// 初始字符串,在兩個(gè)聊天窗口鏈接成功時(shí)輸出,同時(shí)作為兩個(gè)窗口傳遞字符的一個(gè)變量
// 構(gòu)造方法
public MyServer(){
try{//異常處理
JFrame frame=new JFrame("服務(wù)器窗口");
//設(shè)置窗體
frame.setLayout(null);
//讓布局管理器為空,使用絕對(duì)定位
Font fnt=new Font("Serief",Font.PLAIN,40);//字體設(shè)置
Font fnt1=new Font("Serief",Font.PLAIN,20);//字體設(shè)置
//我的用戶名顯示
JLabel lab1=new JLabel("服務(wù)器名:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab1.setBounds(8, 10, 100, 20);
//設(shè)置組件位置及大小
frame.add(lab1);
//添加組件
JTextField text2=new JTextField(30); //單行文本輸入組件
text2.setBounds(150, 10, 200, 20);//設(shè)置組件位置及大小
text2.setEnabled(false);//文本條不可編輯
text2.setText("笑笑聊天室");//輸入內(nèi)容
text2.setFont(fnt1);//設(shè)置字體
frame.add(text2);//添加組件
//服務(wù)器IP顯示
JLabel lab2=new JLabel("當(dāng)前服務(wù)器IP:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab2.setBounds(8, 45, 100, 20);//設(shè)置組件位置及大小
frame.add(lab2);//添加組件
JTextField text3=new JTextField(30);//單行文本輸入組件
text3.setBounds(150, 45, 200, 20);//設(shè)置組件位置及大小
text3.setEnabled(false);
//文本不可編輯
text3.setText("127.0.0.1");//輸入內(nèi)容
text3.setFont(fnt1);//設(shè)置字體
frame.add(text3);
//添加組件
//服務(wù)器端口顯示
JLabel lab3=new JLabel("當(dāng)前服務(wù)器端口:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab3.setBounds(8, 80, 100, 20);//設(shè)置組件位置及大小
frame.add(lab3);//添加組件
JTextField text4=new JTextField(30);//單行文本輸入組件
text4.setBounds(150, 80, 200, 20);//設(shè)置組件位置及大小
text4.setEnabled(false);//文本不可編輯
text4.setText("8888");//輸入內(nèi)容
text4.setFont(fnt1);//設(shè)置字體
frame.add(text4);//添加組件
//聊天記錄顯示
JLabel lab4=new JLabel("聊天記錄如下:",JLabel.LEFT);
//標(biāo)簽實(shí)例化 文本左對(duì)齊
lab4.setBounds(8, 115, 100, 20);//設(shè)置組件位置及大小
frame.add(lab4);//添加組件
final JTextArea text1=new JTextArea();//多行文本輸入組件
text1.setEnabled(false);//文本不可編輯
text1.setLineWrap(true);//自動(dòng)換行
JScrollPane scr=new JScrollPane(text1,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS); //設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr.setBounds(8, 150, 450, 350);//設(shè)置組件位置及大小
frame.add(scr);//添加組件
//聊天輸入窗口及確定
JLabel lab5=new JLabel("請(qǐng)輸入聊天內(nèi)容:",JLabel.LEFT); //標(biāo)簽實(shí)例化,文本左對(duì)齊
lab5.setBounds(8, 500, 100, 20);//設(shè)置組件位置及大小
frame.add(lab5);//添加組件
final JTextArea text5=new JTextArea();//多行文本輸入組件
text5.setLineWrap(true);//自動(dòng)換行
JScrollPane scr2=new JScrollPane(text5,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr2.setBounds(150, 500, 300, 50);//設(shè)置組件位置及大小
frame.add(scr2);//添加組件
final JButton but=new JButton("確定");//設(shè)置確定按鈕
but.setFont(fnt);//添加字體設(shè)置
but.setBounds(480, 500, 200, 50);//設(shè)置組件位置及大小
but.addActionListener(
new ActionListener(){ //采用內(nèi)部匿名類
public void actionPerformed(ActionEvent e){
if(e.getSource()==but){ //判斷觸發(fā)器源是否是提交按鈕
text1.append("笑笑: "+lab10.getText()+"\n ");//在聊天記錄上添加文本
text1.append(text5.getText()+"\n"); //將輸入的聊天內(nèi)容輸出在聊天記錄上
s=text5.getText(); //得到聊天內(nèi)容
text5.setText(""); // 將聊天窗口內(nèi)容設(shè)置為空
}
}
});
frame.add(but);//添加組件
//當(dāng)前時(shí)間顯示
JLabel lab7=new JLabel("時(shí)間顯示:",JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab7.setBounds(450, 20, 100, 20);//設(shè)置組件位置及大小
frame.add(lab7);//添加組件
DateFormat df=DateFormat.getDateTimeInstance();//取得系統(tǒng)時(shí)間
String df2= df.format(new Date()); //將時(shí)間轉(zhuǎn)換成字符串
JLabel lab8=new JLabel(df2,JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab8.setBounds(520, 20, 130, 20);//設(shè)置組件位置及大小
frame.add(lab8);//添加組件
lab10=lab8; //傳遞時(shí)間顯示,以便能在聊天記錄上顯示記錄時(shí)間
new Time(lab8); //使時(shí)間動(dòng)態(tài)顯示
//用戶列表顯示
JLabel lab6=new JLabel("用戶列表:",JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab6.setBounds(500, 40, 100, 20);//設(shè)置組件位置及大小
frame.add(lab6);//添加組件
JTextArea text6=new JTextArea();//標(biāo)簽實(shí)例化,文本左對(duì)齊
text6.setEnabled(false);//文本不可編輯
text6.setLineWrap(true);//自動(dòng)換行
JScrollPane scr3=new JScrollPane(text6,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr3.setBounds(460, 70, 220, 420);//設(shè)置組件位置及大小
frame.add(scr3);//添加組件
//窗口的屬性
frame.setSize(700,600);//窗口大小
frame.getContentPane().setBackground(Color.pink);//窗口的背景顏色
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//關(guān)閉窗口時(shí)關(guān)閉程序
frame.setLocation(100,50);//在電腦桌面上出現(xiàn)的位置
frame.setVisible(true);//顯示窗口
//連個(gè)窗口連接
//建立Server Socket并等待連接請(qǐng)求
ServerSocket server =new ServerSocket(8889);
Socket socket=server.accept();
//連接建立，通過Socket獲取連接上的輸入/輸出流
BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
final PrintWriter out =new PrintWriter(socket.getOutputStream());
//先讀取Client發(fā)送的數(shù)據(jù)，然后從標(biāo)準(zhǔn)輸入讀取數(shù)據(jù)發(fā)送給Client當(dāng)接收到bye時(shí)關(guān)閉連接
String s1="",s2="";
//標(biāo)志字符串,作為傳遞字符串使用
//得到其他窗口傳遞的字符串,并判斷是否結(jié)束
while(!(s1=in.readLine()).equals("bye")){
text6.setText("可可在線"); //當(dāng)連接成功是在用戶列表中 輸出用戶名字
if(!s1.equals("")){ //如果傳遞的字符串不為 空
text1.append("可可: "+lab10.getText()+"\n ");//在聊天記錄上添加文本
text1.append(s1+"\n"); //將輸入的聊天內(nèi)容輸出在聊天記錄上
}
s2=s;//將在聊天窗口中得到的字符串傳遞給輸出字符串
for(;s2.equals("")||s2.equals(null);s2=s){//當(dāng)傳遞的字符串為空時(shí)等待用戶輸入聊天內(nèi)容
}
s="";//將在聊天窗口中得到的字符串設(shè)為空
if(!s2.equals("")!s2.equals(null)){// s2不為空時(shí)做
out.println(s2); //向其他窗口輸出字符串
}
out.flush();//輸出聊天內(nèi)容
}
//關(guān)閉連接
in.close();
out.close();
socket.close();
server.close();
}catch(Exception e){
}
}
//main函數(shù)
public static void main(String args[]){
new Login();//登錄實(shí)現(xiàn) } }
}
}
時(shí)間類 class Time
package com.server;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.swing.JLabel;
import javax.swing.Timer; //時(shí)間類
public class Time {
public Time(JLabel time){
//構(gòu)造方法 this.setTimer(time);
//設(shè)置時(shí)間
}
public void setTimer(JLabel time){
//設(shè)置時(shí)間方法
final JLabel varTime = time;
//傳遞組件
Timer timeAction = new Timer(1000, new ActionListener() {
//時(shí)間監(jiān)聽
public void actionPerformed(ActionEvent e) {
long timemillis = System.currentTimeMillis();//得到系統(tǒng)時(shí)間
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//轉(zhuǎn)換日期顯示格式
varTime.setText(df.format(new Date(timemillis)));//輸出得到的時(shí)間
}
});
timeAction.start(); //開啟線程
}
}
重慶分公司
重慶分公司
