1. java中怎麼用ServerSocket做個有窗口的聊天程序哦!
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class MyServer extends JFrame implements ActionListener{
JTextArea jta;
JTextField jtf;
JButton jb;
JPanel jp;
ServerSocket ss;
Socket socket;
//網路輸入流
Scanner sc;
//網路輸出流
PrintWriter pw;
public MyServer()
{
jta = new JTextArea();
jtf = new JTextField(15);
jb = new JButton("發送");
jp = new JPanel();
jp.add(jtf);
jp.add(jb);
JScrollPane jsp = new JScrollPane(jta);
this.add(jsp,BorderLayout.CENTER);
this.add(jp,BorderLayout.SOUTH);
jb.addActionListener(this);
jtf.addActionListener(this);
//展現
this.setTitle("伺服器");
this.setSize(300,200);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
// 開放埠
try {
ss = new ServerSocket(9000);
System.out.println("等待連接");
socket = ss.accept();
System.out.println("已連接");
//網路輸入流
sc = new Scanner(socket.getInputStream());
//網路輸出流
pw = new PrintWriter(socket.getOutputStream(),true);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while(true)
{
//接受客戶端發送數據
String str = sc.nextLine();
//顯示多行文本框中
jta.append("客戶端說"+str+"\r\n");
}
}
public static void main(String[] args)
{
new MyServer();
}
public void actionPerformed(ActionEvent e) {
// TODO Auto-generated method stub
if(e.getSource()==jb || e.getSource()==jtf)
{
//向客戶端發送數據
pw.println(jtf.getText());
//向多行文本框輸入歷史聊天記錄信息
jta.append("伺服器說:"+jtf.getText()+"\r\n");
//清空單行文本框內容
jtf.setText("");
}
}
}
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
//客戶端程序
public class MyClient extends JFrame implements ActionListener{
JTextArea jta;
JTextField jtf;
JButton jb;
JPanel jp;
Socket socket;
//網路輸入流
Scanner sc;
//網路輸出流
PrintWriter pw;
public MyClient()
{
jta = new JTextArea();
jtf = new JTextField(15);
jb = new JButton("發送");
jp = new JPanel();
jp.add(jtf);
jp.add(jb);
JScrollPane jsp = new JScrollPane(jta);
this.add(jsp,BorderLayout.CENTER);
this.add(jp,BorderLayout.SOUTH);
jb.addActionListener(this);
jtf.addActionListener(this);
//展現
this.setTitle("客戶端");
this.setSize(300,200);
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setVisible(true);
try {
//建立連接
socket = new Socket("127.0.0.1",9000);
//網路輸入流
sc = new Scanner(socket.getInputStream());
//網路輸出流
pw = new PrintWriter(socket.getOutputStream(),true);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
while(true)
{
//接受伺服器發送數據
String str = sc.nextLine();
//顯示在多行文本框
jta.append("伺服器說:"+str+"\r\n");
}
}
public static void main(String[] args) {
new MyClient();
}
public void actionPerformed(ActionEvent e) {
// TODO Auto-generated method stub
if(e.getSource()==jb || e.getSource()==jtf)
{
//向伺服器發送數據
pw.println(jtf.getText());
//顯示在多行文本框
jta.append("客戶端說:"+jtf.getText()+"\r\n");
//清空單行文本框
jtf.setText("");
}
}
}
2. java socket 和php 怎樣實現聊天功能,求幫忙
[java]
view
plain
<span
style="font-size:16px;">package
demo.net;
import
java.io.DataInputStream;
import
java.io.DataOutputStream;
import
java.io.IOException;
import
java.net.ServerSocket;
import
java.net.Socket;
import
java.util.Scanner;
/**
*
模擬qq聊天功能:
實現客戶端與伺服器(一對一)的聊天功能,客戶端首先發起聊天,輸入的內容在伺服器端和客戶端顯示,
*
然後伺服器端也可以輸入信息,同樣信息也在客戶端和伺服器端顯示
*/
//
伺服器類
public
class
ChatServer
{
private
int
port
=
8189;//
默認伺服器埠
public
ChatServer()
{
}
//
創建指定埠的伺服器
public
ChatServer(int
port)
{
this.port
=
port;
}
//
提供服務
public
void
service()
{
try
{//
建立伺服器連接
ServerSocket
server
=
new
ServerSocket(port);
//
等待客戶連接
Socket
socket
=
server.accept();
try
{
//
讀取客戶端傳過來信息的DataInputStream
DataInputStream
in
=
new
DataInputStream(socket
.getInputStream());
//
向客戶端發送信息的DataOutputStream
DataOutputStream
out
=
new
DataOutputStream(socket
.getOutputStream());
//
獲取控制台輸入的Scanner
Scanner
scanner
=
new
Scanner(System.in);
while
(true)
{
//
讀取來自客戶端的信息
String
accpet
=
in.readUTF();
System.out.println(accpet);
String
send
=
scanner.nextLine();
System.out.println("伺服器:"
+
send);
//
把伺服器端的輸入發給客戶端
out.writeUTF("伺服器:"
+
send);
}
}
finally
{//
建立連接失敗的話不會執行socket.close();
socket.close();
}
}
catch
(IOException
e)
{
e.printStackTrace();
}
}
public
static
void
main(String[]
args)
{
new
ChatServer().service();
}
}
</span>
3. 如何用java tcp socket實現聊天室
一個埠就夠了。底層實現就是socket的鏈接。每次server端accept一個鏈接就會創建一個新的socket用於會話。你可以創建一個類room,包含兩個ws,當鏈接之後,把ws填入到room中。滿了就可以開始聊天室。然後server繼續等待新的ws
4. 怎樣用窗口程序做Java socket編寫聊天程序
也不知道怎麼說怎麼用,我寫的代碼,很久了,用的是awt,感覺Java在應用程序上沒前景所以就沒在深入了……現在主攻J2ee,代碼給你,你自己感覺吧
服務端:
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
boolean started = false;
ServerSocket ss = null;
List<Client> clients = new ArrayList<Client>();
public static void main(String[] args) {
new ChatServer().start();
}
public void start() {
try {
ss = new ServerSocket(8888);
started = true;
} catch (BindException e) {
System.out.println("埠使用中....");
System.out.println("請關掉相關程序並重新運行伺服器!");
System.exit(0);
} catch (IOException e) {
e.printStackTrace();
}
try {
while(started) {
Socket s = ss.accept();
Client c = new Client(s);
System.out.println("a client connected!");
new Thread(c).start();
clients.add(c);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
ss.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class Client implements Runnable {
private Socket s;
private DataInputStream dis = null;
private DataOutputStream dos = null;
private boolean bConnected = false;
public Client(Socket s) {
this.s = s;
try {
dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());
bConnected = true;
} catch (IOException e) {
e.printStackTrace();
}
}
public void send(String str) {
try {
dos.writeUTF(str);
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
try {
while(bConnected) {
String str = dis.readUTF();
System.out.println(str);
for(int i=0; i<clients.size(); i++) {
Client c = clients.get(i);
c.send(str);
}
}
} catch (EOFException e) {
System.out.println("Client closed!");
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if(dis != null) dis.close();
if(dos != null) dos.close();
if(s != null) {
s.close();
//s = null;
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
}
客戶端,開兩個就能聊了……
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class ChatClient extends Frame {
Socket s = null;
DataOutputStream dos = null;
DataInputStream dis = null;
private boolean bConnected = false;
TextField tfTxt = new TextField();
TextArea taContent = new TextArea();
Thread tRecv = new Thread(new RecvThread());
public static void main(String[] args) {
new ChatClient().launchFrame();
}
public void launchFrame() {
setLocation(400, 300);
this.setSize(300, 300);
add(tfTxt, BorderLayout.SOUTH);
add(taContent, BorderLayout.NORTH);
pack();
this.addWindowListener(new WindowAdapter() {
@Override
public void windowClosing(WindowEvent arg0) {
disconnect();
System.exit(0);
}
});
tfTxt.addActionListener(new TFListener());
setVisible(true);
connect();
tRecv.start();
}
public void connect() {
try {
s = new Socket("127.0.0.1", 8888);
dos = new DataOutputStream(s.getOutputStream());
dis = new DataInputStream(s.getInputStream());
System.out.println("connected!");
bConnected = true;
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void disconnect() {
try {
dos.close();
dis.close();
s.close();
} catch (IOException e) {
e.printStackTrace();
}
}
private class TFListener implements ActionListener {
public void actionPerformed(ActionEvent e) {
String str = tfTxt.getText().trim();
tfTxt.setText("");
try {
dos.writeUTF(str);
dos.flush();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
private class RecvThread implements Runnable {
public void run() {
try {
while(bConnected) {
String str = dis.readUTF();
taContent.setText(taContent.getText() + str + '\n');
}
} catch (SocketException e) {
System.out.println("�˳��ˣ�bye!");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
5. 用java的Socket編寫的小小小聊天工具,在本機調試成功,但是在兩台能互相ping通的電腦卻不能連接上
建議先用一個最簡單的程序測試客戶端鏈接伺服器,這樣可以排除很多干擾,下面兩個類已經是客戶端和伺服器的最簡代碼了,你先測一下,如果仍不能連接,把異常信息發上來看看。
另:Socket連接容易出問題的地方:
1)埠號沖突,伺服器無法啟動;
2)IP地址錯誤,IP地址分本機地址、區域網地址和廣域網地址,在不同的環境下使用不同的地址測試,如果錯誤將無法被客戶端訪問,還有如果機器安裝了多網卡等問題都會引起錯誤;
3)防火牆禁止Java程序開放埠,不單是伺服器機器的軟防火牆,區域網的防火牆也可能阻止外部的訪問。
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerMain {
public ServerMain() {
try {
ServerSocket ss = new ServerSocket(31647);
Socket s = ss.accept();
System.out.printf("客戶端連接成功:\n%s\n", s.toString());
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ServerMain();
}
}
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
public class ClientMain {
public ClientMain() {
try {
Socket s = new Socket("192.168.1.100", 31647); // 修改IP地址
System.out.println("連接伺服器成功!");
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ClientMain();
}
}
6. 急!!!!求JAVA 帝!JAVA socket 編程,實現聊天程序或其他功能
//這是一個批量文件傳輸程序,先運行server,然後運行client。即可將client端的e:\\1文件內的所有內容傳輸給server端,並按照原來的文件夾結構放在server端電腦的e:\\2文件夾內
/*
* MyClient.java
*
* Created on 2009年8月16日, 下午1:37
*
* To change this template, choose Tools | Template Manager
* and open the template in the editor.
*/
import java.io.*;
import java.net.*;
public class MyClient
{
Socket client;
boolean flag=true;
FileInputStream fis;//此輸入流負責讀取本機上要傳輸的文件
DataOutputStream dos;//此輸出流負責向另一台電腦(伺服器端)傳輸數據
DataInputStream dis;//此輸入流負責讀取另一台電腦的回應信息
public static void main(String[] args)
{
new MyClient().ClientStart();
}
public void ClientStart()
{
try
{
client=new Socket("192.168.2.101",30000);//伺服器端的IP,(這個只是在區域網內的)我的是這個,你的根據實際而定
//client=new Socket("localhost",30000);
System.out.println("已連接");
dos=new DataOutputStream(client.getOutputStream());
dis=new DataInputStream(client.getInputStream());
transmit(new File("e:\\1\\"));
String s="/]00";//提示傳輸完畢的標記
byte b[]=s.getBytes();
dos.write(b,0,s.length());
dos.flush();
}
catch(IOException e)
{
System.out.println("Error");
}
}
public void transmit(File f)throws IOException//這是傳輸的核心,而且將被遞歸
{
byte b[];
String ts;
int ti;
for(File f1:f.listFiles())
{ //首先通過if語句判斷f1是文件還是文件夾
if(f1.isDirectory()) //fi是文件夾,則向伺服器端傳送一條信息
{
ts="/]0f"+(f1.getPath().replace("e:\\1\\",""));//"/]0f"用於表示這條信息的內容是文件夾名稱
b=ts.getBytes();
dos.write(b);
dos.flush();
dis.read();
transmit(f1);//由於f1是文件夾(即目錄),所以它裡面很有可能還有文件或者文件夾,所以進行遞歸
}
else
{
fis=new FileInputStream(f1);
ts="/]0c"+(f1.getPath().replace("e:\\1\\",""));//同上,表示這是一個文件的名稱
b=ts.getBytes();
dos.write(b);
dos.flush();
dis.read();
dos.writeInt(fis.available());//傳輸一個整型值,指明將要傳輸的文件的大小
dos.flush();
dis.read();
b=new byte[10000];
while(fis.available()>0)//開始傳送文件
{
ti=fis.read(b);
dos.write(b,0,ti);
dos.flush();
}
dos.flush();
fis.close();
dis.read();
}
}
}
}
/*
* MyServer.java
*
* Created on 2009年8月16日, 上午11:44
*
* To change this template, choose Tools | Template Manager
* and open the template in the editor.
*/
/**
*
* @author Administrator
*/
import java.io.*;
import java.net.*;
public class MyServer
{
ServerSocket server=null;
Socket client=null;
boolean flag=true;
DataInputStream dis;
DataOutputStream dos;
FileOutputStream fos;
public static void main(String[] args)
{
new MyServer().ServerStart();
}
public void ServerStart()
{
try
{
server=new ServerSocket(30000);
System.out.println("埠號:"+server.getLocalPort());
client=server.accept();
System.out.println("連接完畢");
dis=new DataInputStream(client.getInputStream());
dos=new DataOutputStream(client.getOutputStream());
String answer="g";
byte ans[]=answer.getBytes();
byte b[]=new byte[1000];
int ti;
new File("e:\\2").mkdirs();
while(flag)
{
ti=dis.read(b);
dos.write(ans);
String select=new String(b,0,ti);
if(select.contains("/]0f"))
{
File f=new File("e:\\2\\"+(select.replace("/]0f","")));
System.out.println("creat directory");
f.mkdirs();
}
else if(select.contains("/]0c"))
{
fos=new FileOutputStream("e:\\2\\"+(select.replace("/]0c","")));
String cs;
boolean cflag=true;
int tip=dis.readInt();
dos.write(ans);
while(tip>0)
{
ti=dis.read(b,0,(tip>1000?1000:tip));
tip=tip-ti;
cs=new String(b,0,4);
fos.write(b,0,ti);
}
fos.flush();
fos.close();
dos.write(ans);
}
else if(select.contains("/]00"))
{
flag=false;
}
}
dis.close();
client.close();
server.close();
}
catch(IOException e)
{
System.out.println("Error");
}
}
}
7. 基於java socket編程實現多用戶的聊天問題
你只實現了單工聊天功能, 並沒有實現雙工聊天功能。 也就是說,伺服器端 沒有實現 客戶端A和客戶端B的通信 。 你會mv模式吧, 在model功能層里開一個線程 並用 s.accept()接受從客戶端 發來的套接字,然後轉給另一個客戶端,如果這條路打通了 你就可以 實現雙工通信, 不是很難的 ,細心點 試試看。
8. 怎麼用java socket編程實現聊天
如果你要代碼,可以Q我768446359,如果其中有不懂(是思路上的,不是那種控制台錯誤,當然控制台錯誤也可以)問我,只是我只能保證思路方面解釋清楚,如果我寫的代碼在你的電腦出現其他我沒遇到的問題,我可能沒時間去想!還有,我的是單伺服器,多客戶端,客戶端直接相互可以聊天,不知道是不是你想要的?
。。。 ------最後,希望採納!畢竟我們純手打!
9. Java Socket編程我寫了個簡單聊天程序 沒有用線程 發送在窗口輸出流 為什麼不能發送消息 難道這樣做不行
空指針,你用debug模式跟蹤一下,你的某個對象的值是null,然後你就用丫的方法了。我懷疑是這個:if(arg0.getSource()==button_1){
你都沒判斷arg0是不是null啊,直接就用方法。
10. 怎麼寫個java socket 程序,能相互聊天
代碼那可長啦 我給你發一個吧 udp協議做的 我找找
public void sendMessage() {
//ipjh是一個ip集合 是一個list對象
for(int k=0;k<ipjh.size();k++){
String msg = tfMsg.getText().trim();
if("".equals(address)) {
JOptionPane.showMessageDialog(this, "請輸入發送地址!");
//tfAddress.requestFocus();
return;
}
if("".equals(msg)) {
JOptionPane.showMessageDialog(this, "請輸入消息!");
//tfAddress.requestFocus();
return;
}
try {
//構造數據報
InetAddress toAddr = InetAddress.getByName(ipjh.get(k));
String shuju = yhm+"說:"+msg.toString();
byte[] pData = shuju.getBytes();
DatagramPacket packet = new DatagramPacket(pData,pData.length,toAddr,3000);
//發送數據報
new DatagramSocket().send(packet);
} catch (Exception e) {
//e.printStackTrace();
JOptionPane.showMessageDialog(this, "消息發送失敗,原因:" + e.getMessage());
}
}
}