مساعدة في Chatting Program Using Socket

#130 نوفمبر 2008 في 19:38 صاحب الموضوع

السلام عليكم ورحمة الله وبركاته

لدي برنامج chatting يعمل على الشبكة باستخدام socket ، الملفات كتالي:

ChatServer.java

ChatServerThread.java

ChatClient.java

ChatClientThread.java

اي اربع classes

المشكلة انه بتوزيع الكود بين هذه الملفات او الاربع classes اصبح صعب الفهم ومعقد

فهل يمكن وضعه داخل ملفين فقط ، اي two classes

ChatClient.java

ChatServer.java

الملفات في المرفقات وايضا مدمجة مع الموضوع:

first class

ChatServer

انسخ الكود

import java.net.*;
import java.io.*;
public class ChatServer implements Runnable
{
private ChatServerThread clients[] = new ChatServerThread[2];
private ServerSocket server = null;
private Thread thread = null;
private int clientCount = 0;
public ChatServer( int port )
{
try
{
System.out.println("Binding to port " + port + ", please wait ...");
server = new ServerSocket(port);
System.out.println("Server started: " + server);
start();
}
catch(IOException ioe)
{
System.out.println("Can not bind to port " + port + ": " + ioe.getMessage());
}
}
public void run()
{
while ( thread != null ) // or while ( true )
{
try
{
System.out.println("Waiting for a client ...");
addThread( server.accept()); // listening
}
catch(IOException ioe)
{
System.out.println("Server accept error: " + ioe);
stop();
}
}
}
public void start()
{
if (thread == null)
{
thread = new Thread(this);
thread.start();
}
}
public void stop()
{
if ( thread != null )
{
thread.stop();
thread = null;
}
}
private int findClient( int ID )
{
for (int i = 0; i < clientCount; i++)
if ( clients[i].getID() == ID )
return i;
return -1;
}
public synchronized void handle( int ID, String input )
{
if ( input.equals(".bye") )
{
clients[ findClient(ID) ].send(".bye");
remove( ID );
}
else
for ( int i = 0; i < clientCount; i++)
clients[i].send( ID + ": " + input );
}
public synchronized void remove( int ID )
{
int pos = findClient( ID );
if ( pos >= 0 )
{
ChatServerThread toTerminate = clients[pos];
System.out.println("Removing client thread " + ID + " at " + pos);
if ( pos < clientCount-1 )
for (int i = pos+1; i < clientCount; i++)
clients[i-1] = clients[i];
clientCount--;
try
{
toTerminate.close();
}
catch(IOException ioe)
{
System.out.println("Error closing thread: " + ioe);
}
toTerminate.stop();
}
}
private void addThread( Socket socket )
{
if ( clientCount < clients.length )
{
System.out.println("Client accepted: " + socket );
clients[clientCount] = new ChatServerThread( this, socket );
try
{
clients[clientCount].open();
clients[clientCount].start();
clientCount++;
}
catch(IOException ioe)
{
System.out.println("Error opening thread: " + ioe);
}
}
else
{
System.out.println("Client refused: maximum " + clients.length + " reached.");
try
{
System.out.println("Closing client socket ...");
socket.close();
}
catch( Exception e )
{
System.out.println("Error closing client socket: "+ e );
}
}
}
public static void main(String args[])
{
ChatServer server = null;
if (args.length != 1)
System.out.println("Usage: java ChatServer port");
else
server = new ChatServer( Integer.parseInt(args[0]) );
}
}

second class

ChatServerThread

انسخ الكود

import java.net.*;
import java.io.*;
public class ChatServerThread extends Thread
{
private ChatServer server = null;
private Socket socket = null;
private int ID = -1;
private DataInputStream streamIn = null;
private DataOutputStream streamOut = null;
public ChatServerThread( ChatServer _server, Socket _socket )
{
super();
server = _server;
socket = _socket;
ID = socket.getPort();
}
public void send( String msg )
{
try
{
streamOut.writeUTF(msg);
streamOut.flush();
}
catch(IOException ioe)
{
System.out.println(ID + " ERROR sending: " + ioe.getMessage());
server.remove(ID);
stop(); // OR server.stop?
}
}
public int getID()
{
return ID;
}
public void run()
{
System.out.println("Server Thread " + ID + " running.");
while (true)
{
try
{
server.handle( ID, streamIn.readUTF() );
}
catch(IOException ioe)
{
System.out.println(ID + " ERROR reading: " + ioe.getMessage());
server.remove(ID);
stop();
}
}
}
public void open() throws IOException
{
streamIn = new DataInputStream( new BufferedInputStream( socket.getInputStream()) );
streamOut = new DataOutputStream( new BufferedOutputStream( socket.getOutputStream()) );
}
public void close() throws IOException
{
if ( socket != null )
socket.close();
if ( streamIn != null )
streamIn.close();
if ( streamOut != null )
streamOut.close();
}
}

third class

ChatClient

انسخ الكود

import java.net.*;
import java.io.*;
public class ChatClient implements Runnable
{
private Socket socket = null;
private Thread thread = null;
private DataInputStream console = null;
private DataOutputStream streamOut = null;
private ChatClientThread client = null;
public ChatClient( String serverName, int serverPort )
{
System.out.println("Establishing connection. Please wait ...");
try
{
socket = new Socket( serverName, serverPort );
System.out.println("Connected: " + socket);
start();
}
catch(UnknownHostException uhe)
{
System.out.println("Host unknown: " + uhe.getMessage());
}
catch(IOException ioe)
{
System.out.println("Unexpected exception: " + ioe.getMessage());
}
}
public void run()
{
while ( thread != null )
{
try
{
streamOut.writeUTF( console.readLine() );
streamOut.flush();
}
catch(IOException ioe)
{
System.out.println("Sending error: " + ioe.getMessage());
stop();
}
}
}
public void handle( String msg )
{
if ( msg.equals(".bye") )
{
System.out.println("Good bye. Press RETURN to exit ...");
stop();
}
else
System.out.println(msg);
}
public void start() throws IOException
{
console = new DataInputStream( System.in );
streamOut = new DataOutputStream( socket.getOutputStream() );
if ( thread == null )
{
client = new ChatClientThread( this, socket );
thread = new Thread(this);
thread.start();
}
}
public void stop()
{
if (thread != null)
{
thread.stop();
thread = null;
}
try
{
if ( console != null )
console.close();
if ( streamOut != null )
streamOut.close();
if ( socket != null )
socket.close();
}
catch(IOException ioe)
{
System.out.println("Error closing ...");
}
client.close();
client.stop();
}
public static void main(String args[])
{
ChatClient client = null;
if ( args.length != 2 )
System.out.println("Usage: java ChatClient host port");
else
client = new ChatClient( args[0], Integer.parseInt(args[1]) );
}
}

fourth class

ChatClientThread

انسخ الكود

import java.net.*;
import java.io.*;
public class ChatClientThread extends Thread
{
private Socket socket = null;
private ChatClient client = null;
private DataInputStream streamIn = null;
public ChatClientThread( ChatClient _client, Socket _socket )
{
client = _client;
socket = _socket;
open();
start();
}
public void open()
{
try
{
streamIn = new DataInputStream(socket.getInputStream());
}
catch(IOException ioe)
{
System.out.println("Error getting input stream: " + ioe);
client.stop();
}
}
public void close()
{
try
{
if (streamIn != null) streamIn.close();
}
catch(IOException ioe)
{
System.out.println("Error closing input stream: " + ioe);
}
}
public void run()
{
while (true)
{
try
{
client.handle( streamIn.readUTF() );
}
catch(Exception e)
{
System.out.println("Listening error: " + e.getMessage());
client.stop();
}
}
}
}

#21 ديسمبر 2008 في 01:54

يمكنك وضعهم في ملفين فقط ، لكن لن يتغير شيء في الكود ، وبالتالي يزداد حجم الملف الواحد ،،

فالملف ChatServer.java يقوم في البدايه بعمل Thread يقوم فيه بالأنتظار لأي كلاينت يريد الأتصال فيه ، وحين يتم ذلك ، يقوم بعمل كائن جديد من ChatServerThread.java وهو Thread مهتمه قرائه ما تم ارساله الكلاينت ، وثم يتم استدعاء داله handle نتظر هل هذه الرساله .bye فاذا كانت كذلك فأنها ترجع رساله للعميل تفيده بالخروج ، والا فسوف تطبع الرساله مع رقم العميل _يمكن أنشاء عميلين في البرنامج_ .

لاحظ أن الملف الأول ChatServer يحتوي على مصفوفه من كائنتات ChatServerThread وبالتالي يجب أن يتواجد هذا الكلاس ، سواء في ملف منفصل ، أو يمكنك نسخ محتوياته وضعها في أخر الملف ChatServer وغير حمايه الكلاس من public الى private لأنه لا يمكن وجود كلاسين public في نفس الملف ..

وبنفس المنطق مع الملفين الأخرين ،ChatClient.java تقوم في البدايه بانشاء Thread جديد مهمته هنا ارسال رسائل للخادم، وفي نفس اللحظه تنشىء Thread أخر ChatClientThread.java مهتمه قرائه الرسائل التي تأتيه وطباعتها اذا لم تكن .bye ..

بالنسبه للداله stop ، ففي الملف ChatServer و ChatClient تكون مهتمها غلق Thread الأساسي بالكامل ، وفي الملف الأول تكون بمعني أن السيرفر لن يتسقبل أي اتصال بعد ذلك ، وفي الملف الثاني فهي أيضا تغلق الThread الأساسي هنا والذي مهتمه ارسال الرسائل للخادم وأيضا تغلق الsocket الخاص للتعامل مع الخادم ، وتغلق مجرى الأرسال أيضا ..

أما بالنسبه للملفات ChatServerThread و ChatClientThread فالداله stop تقوم هنا بغلق Thread الحالي والذي هو في الملف الأول Thread التعامل مع الكلاينت ، وفي الثاني Thread قرائه الرسائل من الخادم . على العموم استخدام stop مع الThread غير جيد ، خاصه أنها أصبحت داله ملغيهdeprecated في جافا 1.5 .

بالتوفيق ،،

http://informatic-ar.com منصة تعليمية عربية في علوم الحاسب والبرمجة

https://moalfat.com للكتب الالكترونية والكورسات التعليمية

Everything we see now is just an engineering solution based on old science

#31 ديسمبر 2008 في 13:56

انا اقصد هل يمكن استخدام فقط two classes ؟

البرنامج هذا يقوم بربط كل server thread مع client thread

#42 ديسمبر 2008 في 13:32

اذا مصر على كلاسين فقط ، ضع ال ChatServerThread داخل ChatServer ويكون inner class :) . ونفس الأمر مع الclient ،،

الحل الأخر وهو سيء ، وهو جعل الكلاس ChatServer يرث Thread ، وبدل عمل مصفوفه من ChatServerThread ستقوم بعمل مصفوفه من ChatServer (لأنها Thread أيضا) لكن ستتضطر الى نقل جميع الدوال الموجوده في ChatServerThread الى ChatServer وتغيير اسماء الدوال المتشابهه مع بعض . غير ذلك سيكون حجم الكائن كبير (لأحتوائه على دوال تعامل كسيرفر ودوال تعامل مع الكلاينت ) .. ونفس الأمر مع الكلاينت . لكنه حل غير جيد ، ويفضل الأول ..

بالتوفيق :) .

http://informatic-ar.com منصة تعليمية عربية في علوم الحاسب والبرمجة

https://moalfat.com للكتب الالكترونية والكورسات التعليمية

Everything we see now is just an engineering solution based on old science

#52 ديسمبر 2008 في 14:17

شكرا لك اخي وجدي على الرد

هل يمكن عمل نفس البرنامج باستخدام java RMI؟

#62 ديسمبر 2008 في 15:41

نعم يمكن ، فبدل أن ترسل عن طريق socket رساله string ، ستقوم باستدعاء داله موجوده في الجهه الأخرى وتمرر لها ذلك string ، وستريح نفسك من انشاء thread رئيسي (يتعامل مع أكثر من كلاينت) لأنه السيرفر في RMI يستطيع التعامل مع أي عدد من العملاء ،

بالتوفيق .

http://informatic-ar.com منصة تعليمية عربية في علوم الحاسب والبرمجة

https://moalfat.com للكتب الالكترونية والكورسات التعليمية

Everything we see now is just an engineering solution based on old science

#76 ديسمبر 2008 في 02:37

أخي ممكن تقول لي مامعني الشرطه التي قبل هذه المتغيرات؟

public ChatClientThread( ChatClient _client, Socket _socket )

هل ترمز للعنوان مثل السي ++ لما كنا نقول &variable?

بس التمرير داخل الجافا يتعامل تلقائياً مع الـreferance أثناء التمرير!

ممكن توضحوها لي؟

HeartOutputStream myHeart;
OutputStream myHeartOutStream;

myHeartOutStream = MAllaw.getHeart().getOutputStream();
myHeart = new HeartOutputStream(myHeartOutStream);

while(myHeart.isStillBeating())
myHeart.write("I ♥ Java");

#86 ديسمبر 2008 في 06:41

يجوز استخدام _ في تسميه المتغيرات ، فيمكن أن تجد _number , ويمكن أن يبدأ المتغير بها ..لا مشكله ..

بالنسبه للتمرير في جافا فهو دائما عن طريق القيمه ، وعندما تمرر كائن الى داله فأنت تمرر موقعه (reference) في الذاكره وبالتالي يمكن تغيير قيمته فقط ولن يمكنك جعله يشير لموقع أخر في الذاكره .. راجع الموضوع المثبت (أسئله وأستفسارات) وستجد حديث يدور حول نفس المحور ..

بالتوفيق :) .

http://informatic-ar.com منصة تعليمية عربية في علوم الحاسب والبرمجة

https://moalfat.com للكتب الالكترونية والكورسات التعليمية

Everything we see now is just an engineering solution based on old science

#96 ديسمبر 2008 في 08:05

اقتباس
جوز استخدام _ في تسميه المتغيرات ، فيمكن أن تجد _number , ويمكن أن يبدأ المتغير بها ..لا مشكله ..

أهااااااااا مجرد رمز عادي مثل $ صح ذكرت :)

شكرا أخي وجدي

اقتباس
بالنسبه للتمرير في جافا فهو دائما عن طريق القيمه ، وعندما تمرر كائن الى داله فأنت تمرر موقعه (reference) في الذاكره وبالتالي يمكن تغيير قيمته فقط ولن يمكنك جعله يشير لموقع أخر في الذاكره

أيوا بالضبط أنا قصدي بالنسبه للأوبجكتس فتتعامل تلقائياً مع الـ referance مثل المصفوفات في الجافا تعتبر object لكن المتغيرات العاديه مثل الـint والـfloat وغيرها فتكون by value

مشكور مره أخرى أخي العزيز وجدي على التوضيح :)

HeartOutputStream myHeart;
OutputStream myHeartOutStream;

myHeartOutStream = MAllaw.getHeart().getOutputStream();
myHeart = new HeartOutputStream(myHeartOutStream);

while(myHeart.isStillBeating())
myHeart.write("I ♥ Java");

مساعدة في Chatting Program Using Socket

مواضيع مشابهة