Java Socket聊天室編程(一)之利用socket實現(xiàn)聊天之消息推送
相關(guān)閱讀:Java Socket聊天室編程(二)之利用socket實現(xiàn)單聊聊天室
網(wǎng)上已經(jīng)有很多利用socket實現(xiàn)聊天的例子了,但是我看過很多,多多少有一些問題存在。
這里我將實現(xiàn)一個比較完整的聊天例子,并解釋其中的邏輯。
由于socket這一塊比較大,所以我將分出幾篇來寫一個比較完整的socket例子。
這里我們先來實現(xiàn)一個最簡單的,服務(wù)器與客戶端通訊,實現(xiàn)消息推送的功能。
目的:服務(wù)器與客戶端建立連接,客戶端可以向服務(wù)器發(fā)送消息,服務(wù)器可以向客戶端推送消息。
1,使用java建立socket聊天服務(wù)器
1,SocketUrls 確定ip地址和端口號
public class SocketUrls{ // ip地址 public final static String IP = "192.168.1.110"; // 端口號 public final static int PORT = 8888; }
2,Main 程序的入口
public class Main { public static void main(String[] args) throws Exception { new ChatServer().initServer(); } }
3,Bean 實體類
用戶信息 UserInfoBean
public class Main { public static void main(String[] args) throws Exception { new ChatServer().initServer(); } }
聊天信息 MessageBean
public class MessageBean extends UserInfoBean { private long messageId;// 消息id private long groupId;// 群id private boolean isGoup;// 是否是群消息 private int chatType;// 消息類型;1,文本;2,圖片;3,小視頻;4,文件;5,地理位置;6,語音;7,視頻通話 private String content;// 文本消息內(nèi)容 private String errorMsg;// 錯誤信息 private int errorCode;// 錯誤代碼 //省略get/set方法 }
4,ChatServer 聊天服務(wù),最主要的程序
public class ChatServer { // socket服務(wù) private static ServerSocket server; public Gson gson = new Gson(); /** * 初始化socket服務(wù) */ public void initServer() { try { // 創(chuàng)建一個ServerSocket在端口8080監(jiān)聽客戶請求 server = new ServerSocket(SocketUrls.PORT); createMessage(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 創(chuàng)建消息管理,一直接收消息 */ private void createMessage() { try { System.out.println("等待用戶接入 : "); // 使用accept()阻塞等待客戶請求 Socket socket = server.accept(); System.out.println("用戶接入 : " + socket.getPort()); // 開啟一個子線程來等待另外的socket加入 new Thread(new Runnable() { public void run() { createMessage(); } }).start(); // 向客戶端發(fā)送信息 OutputStream output = socket.getOutputStream(); // 從客戶端獲取信息 BufferedReader bff = new BufferedReader(new InputStreamReader(socket.getInputStream())); // Scanner scanner = new Scanner(socket.getInputStream()); new Thread(new Runnable() { public void run() { try { String buffer; while (true) { // 從控制臺輸入 BufferedReader strin = new BufferedReader(new InputStreamReader(System.in)); buffer = strin.readLine(); // 因為readLine以換行符為結(jié)束點所以,結(jié)尾加入換行 buffer += "\n"; output.write(buffer.getBytes("utf-8")); // 發(fā)送數(shù)據(jù) output.flush(); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }).start(); // 讀取發(fā)來服務(wù)器信息 String line = null; // 循環(huán)一直接收當前socket發(fā)來的消息 while (true) { Thread.sleep(500); // System.out.println("內(nèi)容 : " + bff.readLine()); // 獲取客戶端的信息 while ((line = bff.readLine()) != null) { MessageBean messageBean = gson.fromJson(line, MessageBean.class); System.out.println("用戶 : " + messageBean.getUserName()); System.out.println("內(nèi)容 : " + messageBean.getContent()); } } // server.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("錯誤 : " + e.getMessage()); } } }
2,Android 端作為移動端連接服務(wù)器
1,appliaction 實例化一個全局的聊天服務(wù)
public class ChatAppliaction extends Application { public static ChatServer chatServer; public static UserInfoBean userInfoBean; @Override public void onCreate() { super.onCreate(); } }
2,ip地址和端口號和服務(wù)器保持一致
3,聊天實力類同服務(wù)器端一樣
4,xml布局。登陸,聊天
1,登錄
<?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical"> <EditText android:id="@+id/chat_name_text" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="用戶名" android:text="admin"/> <EditText android:id="@+id/chat_pwd_text" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="密碼" android:text="123123123a" android:inputType="numberPassword" /> <Button android:id="@+id/chat_login_btn" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="登錄" /> </LinearLayout>
2,聊天
<?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical" tools:context=".activity.MainActivity"> <ScrollView android:id="@+id/scrollView" android:layout_width="match_parent" android:layout_height="0dp" android:layout_weight="0.9"> <LinearLayout android:id="@+id/chat_ly" android:layout_width="match_parent" android:layout_height="match_parent" android:orientation="vertical"> </LinearLayout> </ScrollView> <LinearLayout android:layout_width="match_parent" android:layout_height="wrap_content" android:orientation="horizontal"> <EditText android:id="@+id/chat_et" android:layout_width="0dp" android:layout_height="match_parent" android:layout_weight="0.8" /> <Button android:id="@+id/send_btn" android:layout_width="0dp" android:layout_height="match_parent" android:layout_weight="0.2" android:text="發(fā)送" /> </LinearLayout> </LinearLayout>
5,LoginActivity 登陸
public class LoginActivity extends AppCompatActivity { private EditText chat_name_text, chat_pwd_text; private Button chat_login_btn; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_login); chat_name_text = (EditText) findViewById(R.id.chat_name_text); chat_pwd_text = (EditText) findViewById(R.id.chat_pwd_text); chat_login_btn = (Button) findViewById(R.id.chat_login_btn); chat_login_btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { if (getLogin(chat_name_text.getText().toString().trim(), chat_pwd_text.getText().toString().trim())) { getChatServer(); Intent intent = new Intent(LoginActivity.this, MainActivity.class); startActivity(intent); finish(); } } }); } private boolean getLogin(String name, String pwd) { if (TextUtils.isEmpty(name) || TextUtils.isEmpty(pwd)) return false; if (name.equals("admin") && pwd.equals("123123123a")) return true; return false; } private void getChatServer() { ChatAppliaction.chatServer = new ChatServer(); } }
6,MainActivity 聊天
public class MainActivity extends AppCompatActivity { private LinearLayout chat_ly; private TextView left_text, right_view; private EditText chat_et; private Button send_btn; private ViewGroup.LayoutParams layoutParams = new ViewGroup.LayoutParams(ViewGroup.LayoutParams.MATCH_PARENT, ViewGroup.LayoutParams.WRAP_CONTENT); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); chat_ly = (LinearLayout) findViewById(R.id.chat_ly); chat_et = (EditText) findViewById(R.id.chat_et); send_btn = (Button) findViewById(R.id.send_btn); send_btn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { ChatAppliaction.chatServer.sendMessage(chat_et.getText().toString().trim()); chat_ly.addView(initRightView(chat_et.getText().toString().trim())); } }); //添加消息接收隊列 ChatAppliaction.chatServer.setChatHandler(new Handler() { @Override public void handleMessage(Message msg) { if (msg.what == 1) { //發(fā)送回來消息后,更新ui chat_ly.addView(initLeftView(msg.obj.toString())); } } }); } /**靠右的消息 * @param messageContent * @return */ private View initRightView(String messageContent) { right_view = new TextView(this); right_view.setLayoutParams(layoutParams); right_view.setGravity(View.FOCUS_RIGHT); right_view.setText(messageContent); return right_view; } /**靠左的消息 * @param messageContent * @return */ private View initLeftView(String messageContent) { left_text = new TextView(this); left_text.setLayoutParams(layoutParams); left_text.setGravity(View.FOCUS_LEFT); left_text.setText(messageContent); return left_text; } }
7,ChatServer 聊天邏輯,最主要的
public class ChatServer { private Socket socket; private Handler handler; private MessageBean messageBean; private Gson gson = new Gson(); // 由Socket對象得到輸出流,并構(gòu)造PrintWriter對象 PrintWriter printWriter; InputStream input; OutputStream output; DataOutputStream dataOutputStream; public ChatServer() { initMessage(); initChatServer(); } /** * 消息隊列,用于傳遞消息 * * @param handler */ public void setChatHandler(Handler handler) { this.handler = handler; } private void initChatServer() { //開個線程接收消息 receiveMessage(); } /** * 初始化用戶信息 */ private void initMessage() { messageBean = new MessageBean(); messageBean.setUserId(1); messageBean.setMessageId(1); messageBean.setChatType(1); messageBean.setUserName("admin"); ChatAppliaction.userInfoBean = messageBean; } /** * 發(fā)送消息 * * @param contentMsg */ public void sendMessage(String contentMsg) { try { if (socket == null) { Message message = handler.obtainMessage(); message.what = 1; message.obj = "服務(wù)器已經(jīng)關(guān)閉"; handler.sendMessage(message); return; } byte[] str = contentMsg.getBytes("utf-8");//將內(nèi)容轉(zhuǎn)utf-8 String aaa = new String(str); messageBean.setContent(aaa); String messageJson = gson.toJson(messageBean); /** * 因為服務(wù)器那邊的readLine()為阻塞讀取 * 如果它讀取不到換行符或者輸出流結(jié)束就會一直阻塞在那里 * 所以在json消息最后加上換行符,用于告訴服務(wù)器,消息已經(jīng)發(fā)送完畢了 * */ messageJson += "\n"; output.write(messageJson.getBytes("utf-8"));// 換行打印 output.flush(); // 刷新輸出流,使Server馬上收到該字符串 } catch (Exception e) { e.printStackTrace(); Log.e("test", "錯誤:" + e.toString()); } } /** * 接收消息,在子線程中 */ private void receiveMessage() { new Thread(new Runnable() { @Override public void run() { try { // 向本機的8080端口發(fā)出客戶請求 socket = new Socket(SocketUrls.IP, SocketUrls.PORT); // 由Socket對象得到輸入流,并構(gòu)造相應(yīng)的BufferedReader對象 printWriter = new PrintWriter(socket.getOutputStream()); input = socket.getInputStream(); output = socket.getOutputStream(); dataOutputStream = new DataOutputStream(socket.getOutputStream()); // 從客戶端獲取信息 BufferedReader bff = new BufferedReader(new InputStreamReader(input)); // 讀取發(fā)來服務(wù)器信息 String line; while (true) { Thread.sleep(500); // 獲取客戶端的信息 while ((line = bff.readLine()) != null) { Log.i("socket", "內(nèi)容 : " + line); Message message = handler.obtainMessage(); message.obj = line; message.what = 1; handler.sendMessage(message); } if (socket == null) break; } output.close();//關(guān)閉Socket輸出流 input.close();//關(guān)閉Socket輸入流 socket.close();//關(guān)閉Socket } catch (Exception e) { e.printStackTrace(); Log.e("test", "錯誤:" + e.toString()); } } }).start(); } }
寫到這里,已經(jīng)完成了所有的代碼。
這個demo可以實現(xiàn)手機端向服務(wù)器發(fā)送消息,服務(wù)器向手機端發(fā)送消息。
這個demo可以算是推送功能,不過真正的推送沒有這么簡單。作為一個socket的入門了解,可以從中看到socket編程的思想。
以上所述是小編給大家介紹的Java Socket聊天室編程(一)之利用socket實現(xiàn)聊天之消息推送,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
- 使用Java和WebSocket實現(xiàn)網(wǎng)頁聊天室實例代碼
- java socket實現(xiàn)聊天室 java實現(xiàn)多人聊天功能
- java聊天室的實現(xiàn)代碼
- Java基于socket實現(xiàn)簡易聊天室實例
- java實現(xiàn)一個簡單TCPSocket聊天室功能分享
- 基于java編寫局域網(wǎng)多人聊天室
- Java基于UDP協(xié)議實現(xiàn)簡單的聊天室程序
- Java Socket聊天室編程(二)之利用socket實現(xiàn)單聊聊天室
- 使用java基于pushlet和bootstrap實現(xiàn)的簡單聊天室
- Java編寫實現(xiàn)多人聊天室
相關(guān)文章
Java畢業(yè)設(shè)計實戰(zhàn)之醫(yī)院心理咨詢問診系統(tǒng)的實現(xiàn)
這是一個使用了java+Spring+Maven+mybatis+Vue+mysql開發(fā)的醫(yī)院心理咨詢問診系統(tǒng),是一個畢業(yè)設(shè)計的實戰(zhàn)練習,具有心理咨詢問診該有的所有功能,感興趣的朋友快來看看吧2022-01-01Redisson 分布式延時隊列 RedissonDelayedQueue 運行流程
這篇文章主要介紹了Redisson分布式延時隊列 RedissonDelayedQueue運行流程,文章圍繞主題展開詳細的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下2022-09-09詳解MyBatis-Plus Wrapper條件構(gòu)造器查詢大全
這篇文章主要介紹了詳解MyBatis-Plus Wrapper條件構(gòu)造器查詢大全,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-08-08java實現(xiàn)附件預(yù)覽(openoffice+swftools+flexpaper)實例
本篇文章主要介紹了java實現(xiàn)附件預(yù)覽(openoffice+swftools+flexpaper)實例,具有一定的參考價值,感興趣的小伙伴們可以參考一下。2016-10-10springboot后端如何實現(xiàn)攜帶token登陸
這篇文章主要介紹了springboot后端如何實現(xiàn)攜帶token登陸,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-11-11Java基于狀態(tài)模式實現(xiàn)的文檔編輯模式切換功能實例
這篇文章主要介紹了Java基于狀態(tài)模式實現(xiàn)的文檔編輯模式切換功能,結(jié)合實例形式詳細分析了狀態(tài)模式的概念、原理及java使用狀態(tài)模式實現(xiàn)文檔編輯模式切換操作相關(guān)技巧與注意事項,需要的朋友可以參考下2018-05-05利用Spring Boot如何開發(fā)REST服務(wù)詳解
這篇文章主要給大家介紹了關(guān)于利用Spring Boot如何開發(fā)REST服務(wù)的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧。2017-12-12Java Fluent Mybatis 項目工程化與常規(guī)操作詳解流程篇 下
Java中常用的ORM框架主要是mybatis, hibernate, JPA等框架。國內(nèi)又以Mybatis用的多,基于mybatis上的增強框架,又有mybatis plus和TK mybatis等。今天我們介紹一個新的mybatis增強框架 fluent mybatis關(guān)于項目工程化與常規(guī)操作流程2021-10-10