Jabber對于即時消息是一個開放的、基于XML的數(shù)據(jù)模型和協(xié)議。聯(lián)系不斷增加的基于Jabber開放資源和商業(yè)產(chǎn)品的數(shù)目，這種協(xié)議提供了擺脫即時消息服務(wù)器所有權(quán)束縛的一種方法。多種多樣的開放資源Java APIs能夠幫助你建立基于Jabber的服務(wù)器并將即時消息整合到你的應(yīng)用程序中去。在這篇文章中專門闡述了這一點。
創(chuàng)新互聯(lián)公司是一家專業(yè)提供田家庵企業(yè)網(wǎng)站建設(shè),專注與網(wǎng)站建設(shè)、成都做網(wǎng)站、H5技術(shù)、小程序制作等業(yè)務(wù)。10年已為田家庵眾多企業(yè)、政府機構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)的建站公司優(yōu)惠進行中。
即時消息作為個人——個人通迅工具取得了顯著的成功。在有些地方它已經(jīng)作為在線聯(lián)系的首選方法取代了email?，F(xiàn)在，開發(fā)者正將這一技術(shù)應(yīng)用到應(yīng)用程序——個人和應(yīng)用程序——應(yīng)用程序通迅上。
直到最近，也只有少數(shù)服務(wù)提供商掌握了這一技術(shù)。通常流行的即時消息服務(wù)是建立在所有權(quán)協(xié)議基礎(chǔ)上的通迅孤島。實施面臨一個困難的決策：支持多協(xié)議或鎖定到一個單獨的。不管哪種選擇，實現(xiàn)都必須依賴一個屬于即時消息（IM）服務(wù)提供商的服務(wù)器。
開放式協(xié)議能夠幫助開發(fā)者擺脫所有權(quán)陷阱。其優(yōu)勢有多種：開放協(xié)議鼓勵競爭實現(xiàn)的發(fā)展（一些開放資源）。他們鼓勵廣泛采用一種公共協(xié)議，這樣可以阻止通迅孤島和服務(wù)供應(yīng)的孤立主義方法的發(fā)展。用多種方法，開放協(xié)議使因特網(wǎng)成為可能。在即時消息領(lǐng)域，開放協(xié)議確保封閉系統(tǒng)及協(xié)議不會阻礙基于IM服務(wù)器的發(fā)展的互操作性。
Jabber是一種針對即時消息和現(xiàn)場服務(wù)的開放協(xié)議。作為一個公共協(xié)議的最主要的侯選者，Jabber有潛力打破所有權(quán)在即時消息服務(wù)的控制。
這篇文章將解釋如何實踐發(fā)送簡單Jabber消息和開發(fā)一個簡單的基于開放標(biāo)準(zhǔn)及開放資源APIs和產(chǎn)品的布告服務(wù)器。
為什么使用Jabber?
Jabber標(biāo)準(zhǔn)和結(jié)構(gòu)幫助創(chuàng)建一個分布式的IM系統(tǒng)，使人聯(lián)想到分布在因特網(wǎng)上的email系統(tǒng)，用戶在本地連接到這些系統(tǒng)。這個方法直接與象AIM（AOL即時信使）、ICQ、MSN（Microsoft網(wǎng)絡(luò)）及Yahoo這樣的流行服務(wù)提供商提供的單一系統(tǒng)結(jié)構(gòu)作對，在那里一個單獨的中央服務(wù)器或集中服務(wù)器組提供消息服務(wù)。Jabber在其他情形也類似于email結(jié)構(gòu)：Jabber使用一個幾乎與基本SMTP（簡單郵件傳輸協(xié)議）方案一樣的地址方案確定它的終點（人，機器，軟件）地址。例如，myname@elogex.com是一個有效的Jabber地址，或使用Jabber說法叫JID（Jabber ID）。因為這些原因，基于Jabber的系統(tǒng)衡量起來好于已存在的專有系統(tǒng)。加之，對于專有即時消息服務(wù)的網(wǎng)關(guān)允許的協(xié)議是必需的。
多種多樣的Jabber服務(wù)器，包括我們在這篇文章中使用的其中之一，都是自由可使用的，意思就是說你不再需要依賴一個第三方IM服務(wù)提供商（第三方Jabber服務(wù)對于那些要求第三方主機服務(wù)的來說也是有用的）。
標(biāo)準(zhǔn)化
當(dāng)討論Jabber標(biāo)準(zhǔn)的益處時，我應(yīng)該提及IETF IM標(biāo)準(zhǔn)的工作。在寫這篇文章時，其IMPPWG（即時消息和現(xiàn)場協(xié)議工作組）已有多個RFC有效，其中最重要的是：
·RFC 2778:現(xiàn)場和即時消息模型
·RFC 2779:即時消息/現(xiàn)場協(xié)議要求
IMPPWG已經(jīng)起草了一個名叫CPIM（公共現(xiàn)場和即時消息）協(xié)議的因特網(wǎng)標(biāo)準(zhǔn)。Jabber協(xié)議也是一個草擬的因特網(wǎng)標(biāo)準(zhǔn)，但不是IMPPWG工作的部份。
Jabber在哪兒適合這一標(biāo)準(zhǔn)工作呢？依照J(rèn)abber網(wǎng)站，Jabber是“承諾完全支持任何開放實時消息協(xié)議，包括IETF協(xié)議”。如果當(dāng)對于這個IETF協(xié)議的支持增長時，Jabber打算將自己定位為IETF協(xié)議的領(lǐng)導(dǎo)開放資源的平臺。到目前為止，IETF的工作更多地主要集中在收集要求上而不是執(zhí)行。暫時，Jabber僅是一個帶有重要開放資源支持的開放即時消息和現(xiàn)場服務(wù)協(xié)議。結(jié)果，它成為開放即時消息事實上的標(biāo)準(zhǔn)。
另一個值得密切注意的競爭對手是Sun微系統(tǒng)的Jxta協(xié)議，另一個基于XML針對peer-to-peer(P2P)應(yīng)用程序開發(fā)者的協(xié)議。各種各樣的Jxta實施在今天已經(jīng)能夠被提供。但是，由于其起源相對較近，Jxta比起Jabber只有很少的牽引力。
下載并安裝
要開始使用Jabber，你首先需要下載必要的工具：你需要一個Jabber服務(wù)器，一個Jabber客戶端，一個幫助管理和隱藏一些復(fù)雜socket處理的API，XML語法分析，消息創(chuàng)建等等。
Jabber服務(wù)器
為了運行Jabber,你選擇的Jabber服務(wù)器不能有問題，自從他們都接受了標(biāo)準(zhǔn)Jabber XML及與終端應(yīng)用程序通迅以釋放負荷，其也是標(biāo)準(zhǔn)Jabber XML。Jabberd，最初的Jabber服務(wù)器，是開放資源（但不是基于Java），安裝配置簡單并在多數(shù)平臺上都有效，包括Unix、Linux、Windows和Mac OS X。JabaServer開放資源方案也值得提及，但現(xiàn)在，這些基于Java的方案仍不如Jabberd成熟。同時，JabaServer安裝不怎么簡單易懂，因為你必須下載、安裝并配置一個第三方數(shù)據(jù)庫，加上創(chuàng)建必需的數(shù)據(jù)庫規(guī)劃。
對于這篇文章的例子，我選擇Jabberd。當(dāng)二進制及源下載對于jabberd都有效時，我就不在這兒描述怎樣建立一個源發(fā)布。除非你真想自己編譯，可以從jabberd 主頁下載二進制發(fā)布。在Windows平臺上安裝是相對容易的。發(fā)布是一個.exe程序，按照安裝向?qū)б徊揭徊綀?zhí)行。
安裝完成后，你無需配置。在Windows2000，不要求配置。只要雙擊二進制程序就可啟動服務(wù)器。
用戶代理/客戶
我決定使用Exodus客戶端，對于這個方案這是另一個開放資源技術(shù)。我尤其喜歡Exodus的調(diào)試標(biāo)簽，可以允許你正確地查看客戶發(fā)送和接收的XML。另外你能夠作為純粹的XML鍵入Jabber消息并將它們發(fā)送給服務(wù)器。所有這些都證明用Jabber協(xié)議和服務(wù)器測試的有用性。
Exodus的安裝簡單易懂。下載Exodus 壓縮文件（我在文章中使用的是0.6版本）。將文件直接解壓到你想要安裝客戶端的目錄。在這個版本中，文件是些簡單的二進制文件和一個.dll文件。你可以從 Muse 主頁下載Muse API。
發(fā)送你的第一個Jabber消息
要發(fā)送一個Jabber即時消息，你必須初始化Muse Jabber API。通過創(chuàng)建一個JabberContext 類的實例來完成，接下來使用內(nèi)容作為一個參數(shù)到Jabber session factory類的createSession()方法：
1 //初始化Jabber context
2 JabberContext jabberContext = new JabberContext("user", "pass", "localhost");
4 //創(chuàng)建一個Jabber session factory的實例
5 Jabber jabber = new Jabber();
6 //創(chuàng)建新會話
7 JabberSession jabberSession = jabber.createSession(jabberContext);
上面的例子在第2行顯示了一個新context的創(chuàng)建。JabberContext存儲了指定的用戶相關(guān)信息（用戶名、密碼、用戶地址）以及稍后要使用context建立session時包含的一個唯一的會話標(biāo)識。為了闡述意圖，我直接使用了username、password和server。
在第5行，一個Jabber session factory被創(chuàng)建，我們在第7行使用它創(chuàng)建了一個新的JabberSession，Muse進入由Jabber服務(wù)器提供的服務(wù)的主要接口。服務(wù)器的主要服務(wù)是：
·連接服務(wù)： 從Jabber服務(wù)器連接和斷開
·用戶服務(wù)： 針對用戶鑒定及注冊
·現(xiàn)場服務(wù)： 接收從其它用戶/服務(wù)來的及你自己廣播的現(xiàn)場信息
·登記表服務(wù)： 密友列表或地址薄
·聊天服務(wù)： 發(fā)送多種類型的消息—組聊、私聊、標(biāo)題等等
·服務(wù)器服務(wù)： 獲得與由這個Jabber服務(wù)器提供的服務(wù)相關(guān)的信息
·客戶服務(wù)： 獲得關(guān)于其他用戶的信息，比如用戶登錄的最后時間
現(xiàn)在我們已經(jīng)有了一個已經(jīng)初始化的Jabber session，我們能夠用它在我們才創(chuàng)建的JabberSession對象中使用connect()方法去連接到Jabber 服務(wù)器：
8 //連接到服務(wù)器
9 jabberSession.connect("localhost", 5222);
要連接到一個Jabber服務(wù)器，我們指定地址及在指定服務(wù)器上的機器端口號。標(biāo)準(zhǔn)來說，缺省Jabber端口是5222。
現(xiàn)在JabberSession已經(jīng)連接到服務(wù)器，我們能夠在我們的服務(wù)中用login()方法登錄：
10 //登錄到Jabber服務(wù)器
11 jabberSession.getUserService().login();
在第11行，我們使用JabberSession獲得一個到UserService的引用，接下來在我們服務(wù)中調(diào)用login()方法。注意方法自身不指定任何用戶信息。當(dāng)在上面第7行JabberSession被創(chuàng)建時login()從與JabberSession相關(guān)的JabberContext中獲得這些信息。
現(xiàn)在我們已經(jīng)成功登錄到Jabber服務(wù)器，我們能夠開始發(fā)送和接收消息。下面代碼段顯示了如何構(gòu)造一個簡單的標(biāo)題風(fēng)格的消息：
12 //構(gòu)造測試消息
13 JabberChatMessage msg = new
14 JabberChatMessage(JabberChatMessage.TYPE_HEADLINE);
15 msg.setSubject("Hello world");
16 msg.setBody("Hello world");
17 msg.setTo("user2@localhost");
在第13行，我們創(chuàng)建了一個JabberChatMessage實例。單個參數(shù)指定了我們要求的消息類型：TYPE_HEADLINE。JabberChatMessage類的名字容易引起誤解，實際上，它可以用來包含在Jabber協(xié)議中定義的消息的任何四種類型—普通、聊天、標(biāo)題及錯誤。在第15行，setSubject()和setBody()分別指定主題和內(nèi)容。最后，setTo()在第17行設(shè)置消息接收器的JID。
在封裝下，JabberChatMessage將所有這些信息轉(zhuǎn)換成一個內(nèi)在的DOM（文檔對象模型）樹，這樣當(dāng)我們已經(jīng)準(zhǔn)備好發(fā)送消息給Jabber服務(wù)器時能夠輕松產(chǎn)生XML。
最后步驟：用sendMessage()方法發(fā)送消息：
18 //發(fā)送消息
19 jabberSession.sendMessage(msg);
在封裝下
依據(jù)上面例子所得的事實，Muse API有效地隱藏了與連接管理和XML語法分析有關(guān)的所有細節(jié)，因此允許你集中精力在手邊的任務(wù)上：創(chuàng)建一個消息服務(wù)。然而，理解一些基礎(chǔ)協(xié)議交換證明是有用的。讓我們關(guān)注一下當(dāng)我們連接到服務(wù)器時發(fā)生的XML交換，登錄，并象上面代碼描述的一樣發(fā)送消息。在下面的XML交換中，被客戶接收的消息（我們例子代碼）帶了RECV前綴，送到服務(wù)器的消息帶有SEND前綴：
SEND: ?xml version="1.0" encoding="UTF-8" ?
stream:stream to="localhost"
xmlns="jabber:client"
xmlns:stream=""
RECV: stream:stream from="localhost" id="3D160545"
所有的Jabber交換都發(fā)生在一個XML流的上下文。在我們客戶與Jabber服務(wù)器之間連接的生命期間，兩個完全的XML文檔在一個時間傳輸一個片段。上面顯示的最初交換允許客戶開始發(fā)送XML流文檔到服務(wù)器并且服務(wù)器開始發(fā)送XML流文檔到客戶。
下面，一個要求鑒定的信息被發(fā)送給服務(wù)器：
SEND: iq xmlns="jabber:client" type='get' id='id_10028'
query xmlns="jabber:iq:auth"
usernameuser/username
/query
/iq
RECV: iq xmlns="jabber:client" type='result' id='id_10028'
query xmlns="jabber:iq:auth"
usernameuser/username
password /
digest/
sequence482/sequence
token3D15E63A/token
resource /
/query
/iq
在用戶鑒定程序前述那段顯示了第一次交換。開始，客戶向服務(wù)器詢問哪種鑒定方式對于給定用戶是有效的。服務(wù)器段用下面的鑒定方法回答：
·Plain 文本：password /標(biāo)簽
·零知識鑒定：使用sequence和token標(biāo)簽
·digest/：象plain文本，但密碼是SHA-1 (安全無序運算法則)-用用戶的plain文本密碼進行編碼
我們實際上使用digest/，象下面代碼段描述的一樣：
SEND: iq xmlns="jabber:client" type='set' id='id_10030'
query xmlns="jabber:iq:auth"
usernameuser/username
hash425c73373237061edcc5f23ba239c6cc69556f5c/hash
resourceHome/resource
/query
/iq
RECV: iq xmlns="jabber:client" type='result' id='id_10030'/iq
在這一點，用戶連接到服務(wù)器并能夠開始發(fā)送和接收消息：
SEND: message xmlns="jabber:client" type='headline'
id='id_10032' to='user2@localhost'
thread xmlns="jabber:client"id_10033/thread
subject xmlns="jabber:client"Hello world/subject
body xmlns="jabber:client"Hello world/body
/message
上面片段顯示了我們發(fā)送給接收者user2@localhost的測試標(biāo)題消息。
你可能已經(jīng)注意到在前述協(xié)議段有一個重復(fù)出現(xiàn)元素：ID標(biāo)簽。因為session能夠由多個異步會話組成，ID標(biāo)簽匹配查詢并響應(yīng)。
接收消息
自從這篇文章的主要方向是向你顯示如何開發(fā)一個報警系統(tǒng)，我就很少注意消息接收。然而，為了完整性的利益，我應(yīng)該討論在Muse API中處理接收消息的一些有用特性。另外，因為報警服務(wù)是被登錄到Jabber服務(wù)器的用戶執(zhí)行的，你能夠適當(dāng)?shù)仄谕恍┫⒔邮照咴噲D與發(fā)送者通信。
Muse使用一個listener附在session上以接收進入消息的提示。下面代碼顯示了如何創(chuàng)建一個listener并將其附到session——listener實際上附加到連接上，但自從我們的接口是在session級別并且JabberSession類有一個便利的方法添加一個listener，我們就將其附加到session：
1 jabberSession.addMessageListener(
2 new JabberMessageListener() {
3 public void messageReceived(JabberMessageEvent event) {
4 if (event.getMessageType() == JabberCode.MSG_CHAT ) {
5 JabberChatMessage msg =
6 (JabberChatMessage)event.getMessage();
7 JabberChatMessage reply = new
8 JabberChatMessage(JabberChatMessage.TYPE_HEADLINE);
9 reply.setTo(msg.getFrom());
10 reply.setSubject("Re: "+msg.getSubject());
11 reply.setBody(
12 "I'm just a sender: please send messages to someone else");
13
14 //發(fā)送消息
15 jabberSession.sendMessage(reply);
16 }
17 }
18 }
19 );
客戶能夠添加幾個消息listeners，每次一個消息被接收它們都要被調(diào)用。典型的，你為要處理的每一個類型的消息添加一個listener。另一個選擇：為同一種消息類型但在那些消息中的每一種不同的行為添加多個listeners。然而另一種選擇將添加一個要處理所有消息類型的listener。選擇依賴于你想完成什么。
在上面的例子中，一個單獨的listener被附加。Listener必須是實現(xiàn)JabberMessageListener接口的類的一個實例。這個接口要求一個要被執(zhí)行的單個方法： void messageReceived(JabberMessageEvent)。當(dāng)一個消息從服務(wù)器被接收時這個方法將被調(diào)用。在例子代碼中，messageReceived()方法首先檢查在第4行接收的消息類型。自從Jabber用戶代理使用了MSG_CHAT類型發(fā)送消息，就只對這種類型消息才感興趣。在第5行，Jabber消息從JabberMessageEvent 提取。在第9行通過設(shè)置收件人接收消息被用來構(gòu)成一個給消息發(fā)送者的回復(fù)并且在第10行拷貝接收消息的主題。一個缺省錯誤文本被作為消息體在第11行被設(shè)置，并且，在第15行，消息使用前面例子同樣的方法利用JabberSession對象的sendMessage()方法傳輸。
試試Jabber
這篇文章提供了一個對于Jabber協(xié)議及少量你能夠?qū)⑦@一技術(shù)應(yīng)用到你的應(yīng)用程序中去的開放資源方案的基本介紹。對這個協(xié)議有用的應(yīng)用程序多種多樣，并不限于傳統(tǒng)P2P感覺的即時消息領(lǐng)域。例如，jogger.jabber.org提供的Jogger，一個允許你通過發(fā)送一個消息給Weblog應(yīng)用程序（blog）就能更新個人網(wǎng)絡(luò)雜志的有趣服務(wù)。Jabber在用戶服務(wù)應(yīng)用程序及其它結(jié)構(gòu)的協(xié)作類型應(yīng)用程序同樣有很大的影響。
象上面例子所顯示的一樣，你使用一個API如Muse或JabberBeans在少許幾行Java代碼中就能夠完成即時消息功能。記住我不能掩蓋一些Jabber其它重要的特征，如現(xiàn)場服務(wù)和登記表管理，這些在使用時都是相關(guān)的。另一個重要的特征是Jabber服務(wù)器的模塊性和可擴展性，它允許一個開發(fā)者創(chuàng)建新的服務(wù)直接整合進服務(wù)器。
共四個java文件，源代碼如下：
import java.awt.*;
import java.net.*;
import java.awt.event.*;
import java.io.*;
import java.util.Hashtable;
public class ChatArea extends Panel implements ActionListener,Runnable
{
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
Thread threadMessage=null;
TextArea 談話顯示區(qū),私聊顯示區(qū)=null;
TextField 送出信息=null;
Button 確定,刷新談話區(qū),刷新私聊區(qū);
Label 提示條=null;
String name=null;
Hashtable listTable;
List listComponent=null;
Choice privateChatList;
int width,height;
public ChatArea(String name,Hashtable listTable,int width,int height)
{
setLayout(null);
setBackground(Color.orange);
this.width=width;
this.height=height;
setSize(width,height);
this.listTable=listTable;
this.name=name;
threadMessage=new Thread(this);
談話顯示區(qū)=new TextArea(10,10);
私聊顯示區(qū)=new TextArea(10,10);
確定=new Button("送出信息到:");
刷新談話區(qū)=new Button("刷新談話區(qū)");
刷新私聊區(qū)=new Button("刷新私聊區(qū)");
提示條=new Label("雙擊聊天者可私聊",Label.CENTER);
送出信息=new TextField(28);
確定.addActionListener(this);
送出信息.addActionListener(this);
刷新談話區(qū).addActionListener(this);
刷新私聊區(qū).addActionListener(this);
listComponent=new List();
listComponent.addActionListener(this);
privateChatList=new Choice();
privateChatList.add("大家(*)");
privateChatList.select(0);
add(談話顯示區(qū));
談話顯示區(qū).setBounds(10,10,(width-120)/2,(height-120));
add(私聊顯示區(qū));
私聊顯示區(qū).setBounds(10+(width-120)/2,10,(width-120)/2,(height-120));
add(listComponent);
listComponent.setBounds(10+(width-120),10,100,(height-160));
add(提示條);
提示條.setBounds(10+(width-120),10+(height-160),110,40);
Panel pSouth=new Panel();
pSouth.add(送出信息);
pSouth.add(確定);
pSouth.add(privateChatList);
pSouth.add(刷新談話區(qū));
pSouth.add(刷新私聊區(qū));
add(pSouth);
pSouth.setBounds(10,20+(height-120),width-20,60);
}
public void setName(String s)
{
name=s;
}
public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)
{
this.socket=socket;
this.in=in;
this.out=out;
try
{
threadMessage.start();
}
catch(Exception e)
{
}
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==確定||e.getSource()==送出信息)
{
String message="";
String people=privateChatList.getSelectedItem();
people=people.substring(0,people.indexOf("("));
message=送出信息.getText();
if(message.length()0)
{
try {
if(people.equals("大家"))
{
out.writeUTF("公共聊天內(nèi)容:"+name+"說:"+message);
}
else
{
out.writeUTF("私人聊天內(nèi)容:"+name+"悄悄地說:"+message+"#"+people);
}
}
catch(IOException event)
{
}
}
}
else if(e.getSource()==listComponent)
{
privateChatList.insert(listComponent.getSelectedItem(),0);
privateChatList.repaint();
}
else if(e.getSource()==刷新談話區(qū))
{
談話顯示區(qū).setText(null);
}
else if(e.getSource()==刷新私聊區(qū))
{
私聊顯示區(qū).setText(null);
}
}
public void run()
{
while(true)
{
String s=null;
try
{
s=in.readUTF();
if(s.startsWith("聊天內(nèi)容:"))
{
String content=s.substring(s.indexOf(":")+1);
談話顯示區(qū).append("\n"+content);
}
if(s.startsWith("私人聊天內(nèi)容:"))
{
String content=s.substring(s.indexOf(":")+1);
私聊顯示區(qū).append("\n"+content);
}
else if(s.startsWith("聊天者:"))
{
String people=s.substring(s.indexOf(":")+1,s.indexOf("性別"));
String sex=s.substring(s.indexOf("性別")+2);
listTable.put(people,people+"("+sex+")");
listComponent.add((String)listTable.get(people));
listComponent.repaint();
}
else if(s.startsWith("用戶離線:"))
{
String awayPeopleName=s.substring(s.indexOf(":")+1);
listComponent.remove((String)listTable.get(awayPeopleName));
listComponent.repaint();
談話顯示區(qū).append("\n"+(String)listTable.get(awayPeopleName)+"離線");
listTable.remove(awayPeopleName);
}
Thread.sleep(5);
}
catch(IOException e)
{
listComponent.removeAll();
listComponent.repaint();
listTable.clear();
談話顯示區(qū).setText("和服務(wù)器的連接已中斷\n必須刷新瀏覽器才能再次聊天");
break;
}
catch(InterruptedException e)
{
}
}
}
}
ChatServer.java
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer
{
public static void main(String args[])
{
ServerSocket server=null;
Socket you=null;
Hashtable peopleList;
peopleList=new Hashtable();
while(true)
{
try
{
server=new ServerSocket(6666);
}
catch(IOException e1)
{
System.out.println("正在監(jiān)聽");
}
try {
you=server.accept();
InetAddress address=you.getInetAddress();
System.out.println("用戶的IP:"+address);
}
catch (IOException e)
{
}
if(you!=null)
{
Server_thread peopleThread=new Server_thread(you,peopleList);
peopleThread.start();
}
else {
continue;
}
}
}
}
class Server_thread extends Thread
{
String name=null,sex=null;
Socket socket=null;
File file=null;
DataOutputStream out=null;
DataInputStream in=null;
Hashtable peopleList=null;
Server_thread(Socket t,Hashtable list)
{
peopleList=list;
socket=t;
try {
in=new DataInputStream(socket.getInputStream());
out=new DataOutputStream(socket.getOutputStream());
}
catch (IOException e)
{
}
}
public void run()
{
while(true)
{ String s=null;
try
{
s=in.readUTF();
if(s.startsWith("姓名:"))
{
name=s.substring(s.indexOf(":")+1,s.indexOf("性別"));
sex=s.substring(s.lastIndexOf(":")+1);
boolean boo=peopleList.containsKey(name);
if(boo==false)
{
peopleList.put(name,this);
out.writeUTF("可以聊天:");
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{
Server_thread th=(Server_thread)enum.nextElement();
th.out.writeUTF("聊天者:"+name+"性別"+sex);
if(th!=this)
{
out.writeUTF("聊天者:"+th.name+"性別"+th.sex);
}
}
}
else
{
out.writeUTF("不可以聊天:");
}
}
else if(s.startsWith("公共聊天內(nèi)容:"))
{
String message=s.substring(s.indexOf(":")+1);
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{
((Server_thread)enum.nextElement()).out.writeUTF("聊天內(nèi)容:"+message);
}
}
else if(s.startsWith("用戶離開:"))
{
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{ try
{
Server_thread th=(Server_thread)enum.nextElement();
if(th!=thisth.isAlive())
{
th.out.writeUTF("用戶離線:"+name);
}
}
catch(IOException eee)
{
}
}
peopleList.remove(name);
socket.close();
System.out.println(name+"用戶離開了");
break;
}
else if(s.startsWith("私人聊天內(nèi)容:"))
{
String 悄悄話=s.substring(s.indexOf(":")+1,s.indexOf("#"));
String toPeople=s.substring(s.indexOf("#")+1);
Server_thread toThread=(Server_thread)peopleList.get(toPeople);
if(toThread!=null)
{
toThread.out.writeUTF("私人聊天內(nèi)容:"+悄悄話);
}
else
{
out.writeUTF("私人聊天內(nèi)容:"+toPeople+"已經(jīng)離線");
}
}
}
catch(IOException ee)
{
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{ try
{
Server_thread th=(Server_thread)enum.nextElement();
if(th!=thisth.isAlive())
{
th.out.writeUTF("用戶離線:"+name);
}
}
catch(IOException eee)
{
}
}
peopleList.remove(name);
try
{
socket.close();
}
catch(IOException eee)
{
}
System.out.println(name+"用戶離開了");
break;
}
}
}
}
import java.awt.*;
import java.io.*;
import java.net.*;
import java.applet.*;
import java.util.Hashtable;
ClientChat.java
public class ClientChat extends Applet implements Runnable
{
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
InputNameTextField 用戶提交昵稱界面=null;
ChatArea 用戶聊天界面=null;
Hashtable listTable;
Label 提示條;
Panel north, center;
Thread thread;
public void init()
{
int width=getSize().width;
int height=getSize().height;
listTable=new Hashtable();
setLayout(new BorderLayout());
用戶提交昵稱界面=new InputNameTextField(listTable);
int h=用戶提交昵稱界面.getSize().height;
用戶聊天界面=new ChatArea("",listTable,width,height-(h+5));
用戶聊天界面.setVisible(false);
提示條=new Label("正在連接到服務(wù)器,請稍等...",Label.CENTER);
提示條.setForeground(Color.red);
north=new Panel(new FlowLayout(FlowLayout.LEFT));
center=new Panel();
north.add(用戶提交昵稱界面);
north.add(提示條);
center.add(用戶聊天界面);
add(north,BorderLayout.NORTH);
add(center,BorderLayout.CENTER);
validate();
}
public void start()
{
if(socket!=nullin!=nullout!=null)
{ try
{
socket.close();
in.close();
out.close();
用戶聊天界面.setVisible(false);
}
catch(Exception ee)
{
}
}
try
{
socket = new Socket(this.getCodeBase().getHost(), 6666);
in=new DataInputStream(socket.getInputStream());
out=new DataOutputStream(socket.getOutputStream());
}
catch (IOException ee)
{
提示條.setText("連接失敗");
}
if(socket!=null)
{
InetAddress address=socket.getInetAddress();
提示條.setText("連接:"+address+"成功");
用戶提交昵稱界面.setSocketConnection(socket,in,out);
north.validate();
}
if(thread==null)
{
thread=new Thread(this);
thread.start();
}
}
public void stop()
{
try
{
socket.close();
thread=null;
}
catch(IOException e)
{
this.showStatus(e.toString());
}
}
public void run()
{
while(thread!=null)
{
if(用戶提交昵稱界面.get能否聊天()==true)
{
用戶聊天界面.setVisible(true);
用戶聊天界面.setName(用戶提交昵稱界面.getName());
用戶聊天界面.setSocketConnection(socket,in,out);
提示條.setText("祝聊天愉快!");
center.validate();
break;
}
try
{
Thread.sleep(100);
}
catch(Exception e)
{
}
}
}
}
InputNameTextField。java
import java.awt.*;
import java.net.*;
import java.awt.event.*;
import java.io.*;
import java.util.Hashtable;
public class InputNameTextField extends Panel implements ActionListener,Runnable
{
TextField nameFile=null;
String name=null;
Checkbox male=null,female=null;
CheckboxGroup group=null;
Button 進入聊天室=null,退出聊天室=null;
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
Thread thread=null;
boolean 能否聊天=false;
Hashtable listTable;
public InputNameTextField(Hashtable listTable)
{
this.listTable=listTable;
nameFile=new TextField(10);
group=new CheckboxGroup();
male=new Checkbox("男",true,group);
female=new Checkbox("女",false,group);
進入聊天室=new Button("進入");
退出聊天室=new Button("退出");
進入聊天室.addActionListener(this);
退出聊天室.addActionListener(this);
thread=new Thread(this);
add(new Label("昵稱:"));
add(nameFile);
add(male);
add(female);
add(進入聊天室);
add(退出聊天室);
退出聊天室.setEnabled(false);
}
public void set能否聊天(boolean b)
{
能否聊天=b;
}
public boolean get能否聊天()
{
return 能否聊天;
}
public String getName()
{
return name;
}
public void setName(String s)
{
name=s;
}
public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)
{
this.socket=socket;
this.in=in;
this.out=out;
try{
thread.start();
}
catch(Exception e)
{
nameFile.setText(""+e);
}
}
public Socket getSocket()
{
return socket;
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==進入聊天室)
{
退出聊天室.setEnabled(true);
if(能否聊天==true)
{
nameFile.setText("您正在聊天:"+name);
}
else
{
this.setName(nameFile.getText());
String sex=group.getSelectedCheckbox().getLabel();
if(socket!=nullname!=null)
{
try{
out.writeUTF("姓名:"+name+"性別:"+sex);
}
catch(IOException ee)
{
nameFile.setText("沒有連通服務(wù)器"+ee);
}
}
}
}
if(e.getSource()==退出聊天室)
{
try
{
out.writeUTF("用戶離開:");
}
catch(IOException ee)
{
}
}
}
public void run()
{
String message=null;
while(true)
{
if(in!=null)
{
try
{
message=in.readUTF();
}
catch(IOException e)
{
nameFile.setText("和服務(wù)器斷開"+e);
}
}
if(message.startsWith("可以聊天:"))
{
能否聊天=true;
break;
}
else if(message.startsWith("聊天者:"))
{
String people=message.substring(message.indexOf(":")+1);
listTable.put(people,people);
}
else if(message.startsWith("不可以聊天:"))
{
能否聊天=false;
nameFile.setText("該昵稱已被占用");
}
}
}
}
【ClientSocketDemo.java 客戶端Java源代碼】
import java.net.*;
import java.io.*;
public class ClientSocketDemo
{
//聲明客戶端Socket對象socket
Socket socket = null;
//聲明客戶器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明字符串?dāng)?shù)組對象response，用于存儲從服務(wù)器接收到的信息
String response[];
//執(zhí)行過程中，沒有參數(shù)時的構(gòu)造方法，本地服務(wù)器在本地，取默認(rèn)端口10745
public ClientSocketDemo()
{
try
{
//創(chuàng)建客戶端socket，服務(wù)器地址取本地，端口號為10745
socket = new Socket("localhost",10745);
//創(chuàng)建客戶端數(shù)據(jù)輸入輸出流，用于對服務(wù)器端發(fā)送或接收數(shù)據(jù)
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
//獲取客戶端地址及端口號
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í)行過程中，有一個參數(shù)時的構(gòu)造方法，參數(shù)指定服務(wù)器地址，取默認(rèn)端口10745
public ClientSocketDemo(String hostname)
{
try
{
//創(chuàng)建客戶端socket，hostname參數(shù)指定服務(wù)器地址，端口號為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í)行過程中，有兩個個參數(shù)時的構(gòu)造方法，第一個參數(shù)hostname指定服務(wù)器地址
//第一個參數(shù)serverPort指定服務(wù)器端口號
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類對象
ServerSocket serverSocket;
//聲明并初始化服務(wù)器端監(jiān)聽端口號常量
public static final int PORT = 10745;
//聲明服務(wù)器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明InetAddress類對象ip，用于獲取服務(wù)器地址及端口號等信息
InetAddress ip = null;
//聲明字符串?dāng)?shù)組對象request，用于存儲從客戶端發(fā)送來的信息
String request[];
public ServerSocketDemo()
{
request = new String[3]; //初始化字符串?dāng)?shù)組
try
{
//獲取本地服務(wù)器地址信息
ip = InetAddress.getLocalHost();
//以PORT為服務(wù)端口號，創(chuàng)建serverSocket對象以監(jiān)聽該端口上的連接
serverSocket = new ServerSocket(PORT);
//創(chuàng)建Socket類的對象socket，用于保存連接到服務(wù)器的客戶端socket對象
Socket socket = serverSocket.accept();
System.out.println("This is server:"+String.valueOf(ip)+PORT);
//創(chuàng)建服務(wù)器端數(shù)據(jù)輸入輸出流，用于對客戶端接收或發(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();
}
}
交友APP源碼 IM帶音視頻源碼Uniapp 即時通訊安卓蘋果APP源碼
前端開發(fā)語言：VUE（ 安卓，IOS,WEB為一套前端代碼）
服務(wù)器端開發(fā)語言: PHP+WebSocket
數(shù)據(jù)庫：MySql + mongodb
前端打包工具：Hbuilder
服務(wù)器搭建工具：寶塔 + Xshell
短信接口： 支持阿里云
支付接口：支持支付寶
服務(wù)器配置： 4核8G寬帶10兆以上
服務(wù)器系統(tǒng)：Linux Centos 7.6 64位
基本功能說明：
1.發(fā)消息：語音、圖片、視頻、文字、表情、表情包、文件、名片等。
2.聊天：單聊、群聊。
3.自定義消息：發(fā)紅包、轉(zhuǎn)賬。
4.聊天記錄：清空聊天記錄、群管理、加群二維碼控制是否可加。
5.自定義添加鏈接。
6.我的錢包：后臺可以充值、用戶充值、提現(xiàn)等。
7.創(chuàng)建群：可任意創(chuàng)建群，群成員數(shù)量不受限制，好友數(shù)量不受限。
8.群功能：設(shè)置群二維碼、群公告、群共享文件、頂置聊天、消息免打擾，屏蔽群信息、禁言、舉報、群管理、查找聊天記錄、禁止全員相互加好友、清空聊天記錄等。
9.好友聊天：文字、語音、音視頻通話、收藏、照片、小視頻、各種表情、傳送文件、發(fā)送位置、引用回復(fù)、撤回、復(fù)制、刪除、收藏、撤回、錄制、多選、發(fā)紅包，轉(zhuǎn)賬等。
10.生活圈動態(tài)：可以發(fā)送圖文、語音、視頻、可點贊，評論、舉報等。
11.會員登錄：注冊登錄、短信登錄。
12.賬號設(shè)置：修改密碼、語言切換、字體設(shè)置、隱私設(shè)置、安全設(shè)置、一鍵群發(fā)好友消息等。
13.用戶管理：登錄時間、登陸IP、更換頭像、更換名稱、設(shè)置密碼、批量生成用戶。
14.后臺功能： 管理員列表、系統(tǒng)設(shè)置、用戶管理、群組管理、通訊錄管理、財務(wù)管理、會話管理、自定義網(wǎng)站、手機通訊錄
了解更多源碼內(nèi)容，您可以私信我！
如果您也喜歡這篇文章，記得點贊+關(guān)注+評論+轉(zhuǎn)發(fā)喲！[比心][比心][比心]
重慶分公司
重慶分公司
