java消息伺服器

⑴ java：伺服器能主動向客戶端發送消息嗎

不能，服務端只有接受到客戶端的請求，才能往客戶端發送信息，讓客戶端間隔一段時間就訪問次服務端。

⑵ java 伺服器向客戶端發送信息如何處理亂碼

一般發送的中文 通過 get方式提交 會有亂碼 需要重構 也就是轉化為 String a = request.Parameter(name);
a=new String(a.getByte("ISO-8859-1"),"UTF-8"); 將a變數打碎 然後重組 規則是打碎成ISO-8859-1 然後重組成UTF-8 後面的UTF-8也可以是GBK之類的

⑶ 如何用Java實現伺服器確認後客戶端才能發送下一條信息。

1. Server代碼

packagecom.javacodegeeks.android.androidsocketserver;

importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStreamReader;
importjava.net.ServerSocket;
importjava.net.Socket;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.os.Handler;
importandroid.util.Log;
importandroid.widget.TextView;


{
;
;
privateThreadserverThread=null;
privateTextViewtext;
=6000;

@Override
publicvoidonCreate(BundlesavedInstanceState)
{

super.onCreate(savedInstanceState);
setContentView(R.layout.main);

text=(TextView)findViewById(R.id.text2);

updateConversationHandler=newHandler();

this.serverThread=newThread(newServerThread());
this.serverThread.start();

}

@Override
protectedvoidonStop()
{
super.onStop();
try
{
serverSocket.close();
}
catch(IOExceptione)
{
e.printStackTrace();
}
}


{

publicvoidrun()
{
Socketsocket=null;
try
{
serverSocket=newServerSocket(SERVERPORT);
}
catch(IOExceptione)
{
e.printStackTrace();
}
while(!Thread.currentThread().isInterrupted())
{
try
{
socket=serverSocket.accept();//TODO

CommunicationThreadcommThread=newCommunicationThread(socket);
newThread(commThread).start();
}
catch(IOExceptione)
{
Log.i("liu","socket.accept()失敗");

e.printStackTrace();
}
}
}
}


{
privateSocketclientSocket;
privateBufferedReaderinput;

publicCommunicationThread(SocketclientSocket)
{
this.clientSocket=clientSocket;

Log.i("liu","獲取到了client的Socket");

try
{
this.input=newBufferedReader(newInputStreamReader(this.clientSocket.getInputStream()));//TODO
}
catch(IOExceptione)
{
Log.i("liu","input獲取失敗");
e.printStackTrace();
}
}

publicvoidrun()
{
while(!Thread.currentThread().isInterrupted())
{
try
{
Stringread=input.readLine();//TODO
Log.i("liu",read);
updateConversationHandler.post(newupdateUIThread(read));
}
catch(IOExceptione)
{
Log.i("liu","input讀取失敗");
e.printStackTrace();
}
}
}
}


{
privateStringmsg;

publicupdateUIThread(Stringstr)
{
this.msg=str;
}

@Override
publicvoidrun()
{
text.setText(text.getText().toString()+"ClientSays:"+msg+"
");
}

}

}

2. Client代碼：

packagecom.javacodegeeks.android.androidsocketclient;

importjava.io.BufferedWriter;
importjava.io.IOException;
importjava.io.OutputStreamWriter;
importjava.io.PrintWriter;
importjava.net.InetAddress;
importjava.net.Socket;
importjava.net.UnknownHostException;
importandroid.app.Activity;
importandroid.os.Bundle;
importandroid.util.Log;
importandroid.view.View;
importandroid.widget.EditText;


{
privateSocketsocket;
=4000;
_IP="10.0.2.2";

@Override
publicvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);

newThread(newClientThread()).start();
}

publicvoidonClick(Viewview)
{
try
{
EditTextet=(EditText)findViewById(R.id.EditText01);
Stringstr=et.getText().toString();

Log.i("liu","點擊按鈕");

PrintWriterout=newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);//TODO
out.println(str);
}
catch(Exceptione)
{
Log.i("liu","write失敗");
e.printStackTrace();
}
}


{

@Override
publicvoidrun()
{
try
{
InetAddressserverAddr=InetAddress.getByName(SERVER_IP);
socket=newSocket(serverAddr,SERVERPORT);
}
catch(UnknownHostExceptione1)
{
e1.printStackTrace();
}
catch(IOExceptione1)
{
e1.printStackTrace();
}
}
}
}

⑷ Java Web 伺服器的消息推送 幾種方案

⑸ java伺服器推送消息給android

幾種常見的解決方案實現原理
1）輪詢(Pull)方式：客戶端定時向伺服器發送詢問消息，一旦伺服器有變化則立即同步消息。

2）SMS(Push)方式：通過攔截SMS消息並且解析消息內容來了解伺服器的命令，但這種方式一般用戶在經濟上很難承受。

3）持久連接(Push)方式：客戶端和伺服器之間建立長久連接，這樣就可以實現消息的及時行和實時性。

3、消息推送解決方案概述

A、C2DM雲端推送方案

在Android手機平台上，Google提供了C2DM（Cloudto Device Messaging）服務。Android
Cloud to Device Messaging (C2DM)是一個用來幫助開發者從伺服器向Android應用程序發送數據的服務。該服務提供了一個簡單的、輕量級的機制，允許伺服器可以通知移動應用程序直接與伺服器進行通信，以便於從伺服器獲取應用程序更新和用戶數據。

該方案存在的主要問題是C2DM需要依賴於Google官方提供的C2DM伺服器，由於國內的網路環境，這個服務經常不可用。

B、MQTT協議實現Android推送

採用MQTT協議實現Android推送功能也是一種解決方案。MQTT是一個輕量級的消息發布/訂閱協議，它是實現基於手機客戶端的消息推送伺服器的理想解決方案。

wmqtt.jar
是IBM提供的MQTT協議的實現。我們可以從這里（https://github.com/toku/AndroidPushNotificationsDemo）下載該項目的實例代碼，並且可以找到一個採用php書寫的伺服器端實現（https://github.com/toku/PhpMQTTClient）。

C、RSMB實現推送功能

Really Small Message Broker (RSMB)
，是一個簡單的MQTT代理，同樣由IBM提供，其查看地址是：http://www.alphaworks.ibm.com/tech/rsmb。預設打開1883埠，應用程序當中，它負責接收來自伺服器的消息並將其轉發給指定的移動設備。SAM是一個針對MQTT寫的PHP庫。我們可以從這個http://pecl.php.net/package/sam/download/0.2.0地址下載它.

D、XMPP協議實現Android推送

Google官方的C2DM伺服器底層也是採用XMPP協議進行的封裝。XMPP(可擴展通訊和表示協議)是基於可擴展標記語言（XML）的協議，它用於即時消息（IM）以及在線探測。這個協議可能最終允許網際網路用戶向網際網路上的其他任何人發送即時消息。

androidpn是一個基於XMPP協議的java開源Android push notification實現。它包含了完整的客戶端和伺服器端。但也存在一些不足之處：

1）
比如時間過長時，就再也收不到推送的信息了。

2）性能上也不夠穩定。

3）如果將消息從伺服器上推送出去，就不再管理了，不管消息是否成功到達客戶端手機上。

如果我們要使用androidpn，則還需要做大量的工作，需要理解XMPP協議、理解Androidpn的實現機制，需要調試內部存在的BUG。

⑹ 百度雲推送java伺服器怎麼弄

網路雲（Bai Cloud）是網路推出的一項雲存儲服務，首次注冊即有機會獲得2T的空間，已覆蓋主流PC和手機操作系統，包含Web版、Windows版、Mac版、Android版、iphone版和Windows Phone版，用戶將可以輕松將自己的文件上傳到網盤上，並可跨終端隨時隨地查看和分享。

網路雲推送
網路提供了完整的Demo幫助開發者集成雲推送服務，推送服務SDK通過.jar包和.so文件的方式可以集成到我們自己的工程中。在此之前，需要到網路開發者中心進行應用注冊並獲取API Key，這個作為使用推送服務應用的唯一標示，具體流程我就不贅述了，需要使用的話可以直接訪問網路開發者中心進行查看。
下面主要看看Android_SDK的整體概覽和內部運行機制：

上圖是網路雲推送Android_SDK的框架圖，通過SDK可以繞過復雜的Push HTTP/HTTPS API直接和Push伺服器進行交互，主要提供如下功能：
Push服務初始化以及Client注冊綁定
創建或刪除標簽（Tag）
接收Push Server的通知並提供自定義展現消息方式
推送統計分析功能，包括通知的點擊和刪除統計以及應用使用情況統計
富媒體推送
在Android端，總共實現了三個Receiver和一個Service，其中，一個Receiver是用來處理注冊綁定後接收服務端返回的channelID等信息：
<receiver android:name="com..android.pushservice.RegistrationReceiver" android:process=": bdservice_v1"> <intent-filter> <action android:name="com..android.pushservice.action.METHOD " /> <action android:name="com..android.pushservice.action.BIND_SYNC " /> </intent-filter> <intent-filter> <action android:name="android.intent.action.PACKAGE_REMOVED"/> <data android:scheme="package" /> </intent-filter> </receiver>

第二個Receiver是用於接收系統消息以保證PushService正常運行：
<receiver android:name="com..android.pushservice.PushServiceReceiver" android:process=": bdservice_v1"> <intent-filter> <action android:name="android.intent.action.BOOT_COMPLETED" /> <action android:name="android.net.conn.CONNECTIVITY_CHANGE" /> <action android:name="com..android.pushservice.action.notification.SHOW" /> <action android:name="com..android.pushservice.action.media.CLICK" /> </intent-filter> </receiver>

第三個Receiver就是開發者自己實現的用來接收並處理推送消息：
<receiver android:name="your.package.PushMessageReceiver"> <intent-filter> <!-- 接收 push 消息 --> <action android:name="com..android.pushservice.action.MESSAGE" /> <!-- 接收 bind、setTags 等 method 的返回結果 --> <action android:name="com..android.pushservice.action.RECEIVE" /> </intent-filter> </receiver>

一個Service就是在後台運行的用於保障與Push Server維持長連接並做相關處理的後台服務：
<service android:name="com..android.pushservice.PushService" android:exported="true" android:process=" bdservice_v1"/> <!-- push service end -->

在開發者自己需要處理的廣播接收器中，可以對接收到的推送消息進行處理，Push消息通過 action為com..android.pushservice.action.MESSAGE的Intent把數據發送給客戶端your.package.PushMessageReceiver，消息格式由應用自己決定，PushService只負責把伺服器下發的消息以字元串格式透傳給客戶端。介面調用回調通過action為com..android.pushservice.action.RECEIVE的Intent 返回給your.package.PushMessageReceiver。
PushMessageReceiver.java
/** * Push消息處理receiver * @Author Ryan * @Create 2013-8-6 下午5:59:38 */ public class PushMessageReceiver extends BroadcastReceiver { public static final String TAG = PushMessageReceiver.class.getSimpleName(); @Override public void onReceive(final Context context, Intent intent) { if (intent.getAction().equals(PushConstants.ACTION_MESSAGE)) { //獲取消息內容 String message = intent.getExtras().getString( PushConstants.EXTRA_PUSH_MESSAGE_STRING); //消息的用戶自定義內容讀取方式 Log.i(TAG, "onMessage: " + message); } else if (intent.getAction().equals(PushConstants.ACTION_RECEIVE)) { //處理綁定等方法的返回數據 //PushManager.startWork()的返回值通過PushConstants.METHOD_BIND得到 //獲取方法 final String method = intent .getStringExtra(PushConstants.EXTRA_METHOD); //方法返回錯誤碼。若綁定返回錯誤（非0），則應用將不能正常接收消息。 //綁定失敗的原因有多種，如網路原因，或access token過期。 //請不要在出錯時進行簡單的startWork調用，這有可能導致死循環。 //可以通過限制重試次數，或者在其他時機重新調用來解決。 final int errorCode = intent .getIntExtra(PushConstants.EXTRA_ERROR_CODE, PushConstants.ERROR_SUCCESS); //返回內容 final String content = new String( intent.getByteArrayExtra(PushConstants.EXTRA_CONTENT)); //用戶在此自定義處理消息,以下代碼為demo界面展示用 Log.d(TAG, "onMessage: method : " + method); Log.d(TAG, "onMessage: result : " + errorCode); Log.d(TAG, "onMessage: content : " + content); } } }

通過在入口Activity的onCreate方法中進行推送服務的注冊綁定後，即可在推送管理後台或是自己的應用伺服器上進行消息推送的操作了。
PushManager.startWork(getApplicationContext(),PushConstants.LOGIN_TYPE_API_KEY, "you_api_key");

另外，雲推送提供php、java等Server端的SDK供開發者在自己的伺服器上實現推送服務進行定製化管理和操作。
四、單服務單通道機制
網路雲推送實現了單服務單通道的機制，如果在一台Device上安裝了多款Push SDK的應用，不會為每個應用都創建PushService，而是會採用多應用共享一個PushService的模式。這樣既能減少資源消耗也能降低網路流量。PushService運行於一個獨立進程，沒有和主進程運行於同一進程，所以主進程不需要常駐內存，當有新的Push消息時，PushService會通過Intent發送消息給主進程進行處理。通過Intent，以指定目標應用包名的方式，發送私有消息給應用。應用即不能接收不屬於自己的消息，也不能截取別人的消息，同時又降低了消耗，如下為示意圖：

後記：如今，國內提供Android推送服務的還有很多家，例如個推和極光推送等，實現的原理大同小異，開發者可以根據自身需要進行選擇。

⑺ java中如何建立接受信息的伺服器

importjava.io.*;
importjava.net.*;
publicclassServerSocketTest
{
	publicstaticvoidmain(String[]args)
	{
		ServerSocketserver=null;
		BufferedReaderbr=null;
		try
		{
			server=newServerSocket(8888);
			System.out.println("成功創建伺服器套接字");
			while(true)
			{
				System.out.println("處於等待客戶機連接狀態");
				Socketsocket=server.accept();
				System.out.println("和客戶機建立連接");
				InputStreamis=socket.getInputStream();
				br=newBufferedReader(newInputStreamReader(is));
				Stringlen;
				while((len=br.readLine())!=null)
				{
					System.out.println(len);
				}
			}
		}
		catch(IOExceptione)
		{
			System.out.println("伺服器套接字操作發生異常");
		}
		finally
		{
			try
			{
				if(server!=null)
				{
					server.close();
				}
				if(br!=null)
				{
					br.close();
				}
			}
			catch(IOExceptione)
			{
				System.out.println("關閉伺服器套接字發生異常");
			}
		}
	}
}

⑻ java伺服器接收客戶端請求怎樣實現的

伺服器端代碼：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
* Socket通訊伺服器端
* @author 米強
*
*/
public class ServerMain {

public ServerMain() {
try {
// 構造伺服器ServerSocket對象，參數為伺服器端開放的埠號
ServerSocket ss = new ServerSocket(30102);
System.out.println("伺服器准備就緒！");
// 死循環可以使伺服器持續處於接收客戶端狀態
while(true){
// 該方法使程序阻塞，等待客戶端的鏈接，當監聽到客戶端的鏈接，創建一個Socket對象與客戶端單獨會話
Socket s = ss.accept();
// 為了不影響伺服器監聽其它客戶端，這里開啟了一個線程，由線程處理與這個客戶端的會話
new ServerThread(s).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
new ServerMain();
}

}

/**
* 伺服器端與客戶端會話的線程
*/
class ServerThread extends Thread {
private Socket s = null;
private BufferedReader read = null;
private PrintStream print = null;

public ServerThread(Socket s) {
this.s = s;
try {
// 從Socket中獲取輸入流和輸出流，由於我們只做一個簡單的字元串通訊，所以採用BufferedRead和PrintStream來封裝輸入、輸出流
read = new BufferedReader(new InputStreamReader(s.getInputStream()));
print = new PrintStream(s.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
}

/**
* 線程的運行run方法
*/
public void run() {
try {
String message = null;
// 這里循環可以使伺服器持續的接收客戶端信息。read.readLine()通過輸入流讀取一段字元串，賦值給message變數，如果message字元串不為「exit」則循環，否則結束循環
while (!(message = read.readLine()).equals("exit")){
// 將字元串前面添加「返回：」，再發回客戶端
print.println("返回：" + message);
}
} catch (IOException e) {
} finally {
// 在 finally 代碼塊中無論如何都會執行下面代碼：
try {
// 如果沒有關閉Socket
if(!s.isClosed()){
// 關閉Socket鏈接
s.close();
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}

}

客戶端代碼：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

/**
* Socket通訊客戶端
* @author 米強
*
*/
public class ClientMain {

public ClientMain() {
try {
// 構造與伺服器通訊的Socket對象，參數為伺服器IP地址（String）和埠號（int），埠號需要和伺服器端開放的埠號對應
Socket s = new Socket("192.168.1.100", 30102);
// 啟動一個線程與伺服器通訊，並把鏈接伺服器的Socket對象傳遞過去
new LinkThread(s).start();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
new ClientMain();
}

}

/**
* 與伺服器通訊的線程
*/
class LinkThread extends Thread {
private Socket s = null;
// 輸出流
private PrintStream out = null;
// 緩沖輸入流
private BufferedReader in = null;
// 錄入文字的Scanner對象
private Scanner scanner = null;

public LinkThread(Socket s) {
// 將Socket對象實例保存在全局變數中，因為run方法中我們還要用它斷開鏈接
this.s = s;
try {
// 從Socket中獲取輸入流和輸出流，由於我們只做一個簡單的字元串通訊，所以採用BufferedRead和PrintStream來封裝輸入、輸出流
out = new PrintStream(s.getOutputStream());
in = new BufferedReader(new InputStreamReader(s.getInputStream()));
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}

/**
* 線程的運行run方法
*/
public void run() {
// 構造Scanner對象
scanner = new Scanner(System.in);
System.out.println("提示：如果要結束本次會話，請輸入「exit」指令！");
try {
// 死循環可以使客戶端不斷的向伺服器發送信息，不用擔心循環無法結束，後面的return語句可以結束整個線程。
while(true){
// 提示用戶輸入文字
System.out.print("請輸入：");
// 將用戶輸入的字元串保存在message變數中
String message = scanner.nextLine();
// 通過輸出流發送字元串
out.println(message);
// 清空緩沖，強制輸出
out.flush();
// 獲取伺服器返回的字元串
String str = in.readLine();
// 如果返回的字元串存在
if(str != null){
// 顯示在控制台
System.out.println(str);
}else{
// 提示會話結束，並結束線程
System.out.println("本次會話結束！");
return;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
// 在 finally 代碼塊中無論如何都會執行下面代碼：
try {
// 如果沒有關閉Socket
if(!s.isClosed()){
// 關閉Socket鏈接
s.close();
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}

}

⑼ java socket伺服器怎麼給客戶端發信息

伺服器端和客戶端都是通過SOCKET來進行通信的,首先產生一個
socket實例,通過這個實例,伺服器端調用accept這個方法接收來自客戶端發送的信息.但是在產生socket實例的時候必須初始化一個埠.用來負責接受客戶端的請求！
客戶端要給伺服器發送消息也必須產生一個socket實例，初始化的時候必須指定伺服器的IP地址，並且指定服務接收的埠號,這樣客戶端才能找到伺服器要接收的地方，找到地方就可以發送過去了。和你寫信一樣。找到地址
BufferedReader
in
=
new
BufferedReader(new
InputStreamReader(socket.getInputStream()));
PrintWriter
out
=
new
PrintWriter(socket.getOutputStream());
BufferedReader
wt
=
new
BufferedReader(new
InputStreamReader(System.in));
這個只是用來獲取一個從鍵盤的一個流.傳送給伺服器端的數據都是通過流來表示的。意思是是鍵盤輸入的一個位元組轉化成字元流.並輸出或者寫入！