作者king19880326 (OK的啦～我都可以接受)
看板java
标题[问题] 想请问有关chat room的讯息传递问题@@
时间Tue Jun 3 14:58:30 2008
小弟我最近开始练习写chat room程式
基本的传讯息, 收讯息都没有什麽大问题
可是问题来了, 我写的程式只能够支援英文和数字的传送
如果传送中文, 就会变成??这种乱码
以下是我用来读写socket的code
在伺服器端的程式码是:
import java.io.*;
import java.net.*;
import java.util.*;
public class myChatServer{
public static void main(String[] s){
new myChatServer().go(Integer.parseInt(s[0]));
}
ArrayList clientOutputStreams;
/*
this is use to QUIT the server
*/
class Controller implements Runnable{
BufferedReader reader;
public void run(){
reader = new BufferedReader(new InputStreamReader(System.in));
while(true){
System.out.print("Please input youe command : ");
try{
if(reader.readLine().equals("QUIT")) System.exit(0);
}catch(Exception ex){
;
}
}
}
}
class ClientHandler implements Runnable{
BufferedReader reader;
Socket sock;
public ClientHandler(Socket clientSocket){
try{
sock = clientSocket;
// read message form every client
reader = new BufferedReader(new InputStreamReader(sock.getInputStream()));
}catch(Exception ex){
ex.printStackTrace();
}
}
public void run(){
String message;
try{
while((message = reader.readLine()) != null){
tellEveryone(message);
}
}catch(Exception ex){
ex.printStackTrace();
}
}
} // end of inclass
public void go(int port){
Thread control = new Thread(new Controller());
control.start();
clientOutputStreams = new ArrayList();
try{
// create the server socket
ServerSocket serverSock = new ServerSocket(port);
while(true){
// will bock until new client connect
Socket clientSocket = serverSock.accept();
// get the new client InputStream
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
writer.println("Welcome to join this chat room!!");
writer.println("Have a good time :)");
clientOutputStreams.add(writer);
// each client we create a thread to handle
Thread t = new Thread(new ClientHandler(clientSocket));
t.start();
}
}catch(Exception ex){
ex.printStackTrace();
}
}
public void tellEveryone(String message){
Iterator it = clientOutputStreams.iterator();
while(it.hasNext()){
try{
// send out the message
PrintWriter writer = (PrintWriter)it.next();
writer.println(message);
writer.flush();
}catch(Exception ex){
ex.printStackTrace();
}
}
}
}
这是client的程式码:
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;
import java.net.*;
public class myChatClient{
protected JFrame frame;
protected JTextField nickName;
protected JTextField serverAddr;
protected JTextField serverPort;
protected JButton button;
protected JTextArea message;
protected JTextArea typeIn;
protected Socket socket = new Socket();
protected BufferedReader reader;
protected PrintWriter writer;
public static void main(String[] s){
// create the myChatClient Object
myChatClient client = new myChatClient();
// client begin to run
client.go();
}
public void go(){
setupGUI();
setupEventListener();
}
protected void setupEventListener(){
button.addActionListener(new buttonListener());
}
/*
we use button to connect and send message
*/
class buttonListener implements ActionListener{
public void actionPerformed(ActionEvent event){
if(socket.isConnected()){
String message = nickName.getText() + " > " + typeIn.getText();
try{
writer.println(message);
writer.flush();
}catch(Exception ex){
ex.printStackTrace();
}
typeIn.setText("");
typeIn.requestFocus();
}else{
connect();
/*
cread a thread which use to receive message from server
*/
Thread readerThread = new Thread(new IncomingReader());
readerThread.start();
((JButton)event.getSource()).setLabel("Send");
typeIn.setEditable(true);
try{
writer.println(nickName.getText() + " has join this chat room");
writer.flush();
}catch(Exception ex){
ex.printStackTrace();
}
}
//set the thread to receive message from server
}
}
protected void connect(){
try{
// create the socket which connect to server
socket = new Socket(serverAddr.getText(), Integer.parseInt(serverPort.getText()));
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
writer = new PrintWriter(socket.getOutputStream());
}catch(IOException ex){
ex.printStackTrace();
}
}
/*
here is just GUI
*/
protected void setupGUI(){
frame = new JFrame("myChat");
frame.setSize(600, 440);
frame.setResizable(false);
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
JPanel panel1 = new JPanel();
panel1.add(new JLabel("Nickname"));
panel1.add(nickName = new JTextField(5));
panel1.add(new JLabel("Chat Room"));
panel1.add(serverAddr = new JTextField(10));
panel1.add(new JLabel("Port Number"));
panel1.add(serverPort = new JTextField(5));
frame.getContentPane().add(BorderLayout.NORTH, panel1);
JPanel panel2 = new JPanel();
panel2.setBorder(BorderFactory.createTitledBorder("Message"));
message = new JTextArea(14, 47);
message.setLineWrap(true);
message.setWrapStyleWord(true);
message.setEditable(false);
JScrollPane JScrollPane1 = new JScrollPane(message);
JScrollPane1.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
JScrollPane1.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);
panel2.add(JScrollPane1);
frame.getContentPane().add(BorderLayout.CENTER, panel2);
JPanel panel3 = new JPanel();
panel3.setLayout(new BoxLayout(panel3, BoxLayout.X_AXIS));
panel3.setBorder(BorderFactory.createTitledBorder("Your TypeIn"));
typeIn = new JTextArea(5, 45);
typeIn.setLineWrap(true);
typeIn.setEditable(false);
panel3.add(new JScrollPane(typeIn));
button = new JButton("Connect");
panel3.add(button);
frame.getContentPane().add(BorderLayout.SOUTH, panel3);
frame.setVisible(true);
}
class IncomingReader implements Runnable{
/*
we append the received message in the TextArea
*/
public void run(){
try{
String newMessage;
while((newMessage = reader.readLine()) != null){
message.append(newMessage + "\n");
}
}catch(Exception ex){
ex.printStackTrace();
}
}
}
}
谢谢各位大大指教<(__)>
--
※ 发信站: 批踢踢实业坊(ptt.cc)
◆ From: 140.112.243.43
1F：推 superlubu:设 UTF-8 为 charset, 看 InputStreamReader 和 06/03 15:19
2F：→ superlubu:PrintWriter 的 API 06/03 15:20
3F：→ king19880326:我试试看@@ 感谢感谢OTZ 06/03 15:27
4F：推 PsMonkey:你不要挑战作业文条款阿阿阿阿阿 06/03 16:33
5F：→ king19880326:这是我自己写的..也不是作业啊... 06/03 17:12
6F：推 Nipple5566:跟我的期末proj. 很像 06/03 20:19
7F：推 sunSimon:`朝圣 05/16 02:23