devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用Android Studio和阿里云数据库实现一个远程聊天程序_android studio在线聊天

作者：Cpp五条 | 2024-04-10 20:24:42

赞

踩

android studio在线聊天

没有阿里云数据库的可以买个最便宜的，我是新用户9.9元买了一个

 

1.买到后点击左上角的工作台

2.

3.

 4.

 5.

6.

7.

8.

9.

10.

11.

12.

13.

开始写Android Studio项目代码了，先来看看我的项目结构

依赖包下载地址 Central Repository: mysql/mysql-connector-java (maven.org)

我第一次下了个版本比较新的发现会报错，由于我能力有限，所以就老实下载一个低版本的

添加依赖包应该都会了吧，不要忘了添加后还要添加到模块

MainActivity代码如下

注意代码里涉及SQL语句，这里要根据你之前新建的数据库和新建的表来写，我新建的表是test

  1. import android.os.Bundle;
  2. import android.os.Looper;
  3. import android.view.View;
  4. import android.widget.Button;
  5. import android.widget.EditText;
  6. import android.widget.TextView;
  7. import android.widget.Toast;
  8.  
  9. import androidx.appcompat.app.AppCompatActivity;
  10.  
  11. import java.sql.Connection;
  12. import java.sql.PreparedStatement;
  13. import java.sql.ResultSet;
  14. import java.sql.SQLException;
  15.  
  16. public class MainActivity extends AppCompatActivity {
  17.     private TextView t1;  //用于显示获取的信息
  18.     private Button sendmsg;  //发送消息按钮
  19.     private EditText et_msg;//用户输入信息框
  20.     private String user="user"; //默认用户昵称
  21.     private boolean T=false;//发送标志位
  22.     //数据库连接类对象
  23.     private static Connection con = null;
  24.     private static PreparedStatement stmt = null;
  25.     private Button revise;
  26.     private EditText et_revise;
  27.  
  28.     @Override
  29.     protected void onCreate(Bundle savedInstanceState) {
  30.         super.onCreate(savedInstanceState);
  31.         setContentView(R.layout.activity_main);
  32.         //初始化
  33.         t1 = findViewById(R.id.t1);
  34.         et_msg = findViewById(R.id.msg);
  35.         et_revise = findViewById(R.id.reviseText);
  36.         sendmsg = findViewById(R.id.button);
  37.         revise = findViewById(R.id.revise);
  38.         revise.setOnClickListener(new View.OnClickListener() {
  39.             @Override
  40.             public void onClick(View view) {
  41.                 user = et_revise.getText().toString();
  42.                 Toast.makeText(MainActivity.this,"修改成功",Toast.LENGTH_SHORT).show();
  43.             }
  44.         });
  45.         sendmsg.setOnClickListener(new View.OnClickListener() {
  46.             @Override
  47.             public void onClick(View v) { T=true; }
  48.         });
  49.         //TODO 启动发送线程，用按钮控制发送标志位T，来进行发送信息【注意：连接数据库必须在线程内，不然会报错】
  50.         Threads_sendmsg threads_sendmsg = new Threads_sendmsg();
  51.         threads_sendmsg.start();
  52.         //TODO 启动获取数据线程，读取数据库里的信息【注意：连接数据库必须在线程内，不然会报错】
  53.         Threads_readSQL threads_readSQL = new Threads_readSQL();
  54.         threads_readSQL.start();
  55.  
  56.     }
  57.  
  58.     class Threads_sendmsg extends Thread {
  59.  
  60.         @Override
  61.         public void run() {
  62.             while (true){
  63.                 while (T){
  64.                     try {
  65.                         con = MySQLConnections.getConnection();
  66.                     } catch (Exception e) {
  67.                         e.printStackTrace();
  68.                     }
  69.                     try {
  70.                              //注意你数据库中是否有 test 这个表，我新建的表是 test
  71.                             //还有我的属性，是否和我一样呢，不一样就按你自己的来吧
  72.                         String msg =et_msg.getText().toString().trim(); //用户发送的信息
  73.  
  74.                         if (msg.isEmpty()){
  75.  
  76.                             Looper.prepare();
  77.                             Toast.makeText(MainActivity.this, "消息为空", Toast.LENGTH_SHORT).show();
  78.                             Looper.loop();
  79.                             T=false;
  80.                             break;
  81.                         }
  82.                         if (msg.length()>199){
  83.                             Looper.prepare();
  84.                             Toast.makeText(MainActivity.this, "消息长度超过限制", Toast.LENGTH_SHORT).show();
  85.                             Looper.loop();
  86.                             T=false;
  87.                             break;
  88.                         }
  89.  
  90.                         if (con!=null) {
  91.                             runOnUiThread(new Runnable() {
  92.                                 @Override
  93.                                 public void run() {
  94.                                     Toast.makeText(MainActivity.this, "发送成功", Toast.LENGTH_SHORT).show();
  95.                                 }
  96.                             });
  97.                             String sql = "insert into test(name,msg,sign)  values(?,?,?)";
  98.                             stmt = con.prepareStatement(sql);
  99.                             // 关闭事务自动提交 ,这一行必须加上
  100.                             con.setAutoCommit(false);
  101.                             stmt.setString(1,user);
  102.                             stmt.setString(2,msg);
  103.                             stmt.setInt(3,1);
  104.                             stmt.addBatch();
  105.                             stmt.executeBatch();
  106.                             con.commit();
  107.                         }
  108.                     }catch (SQLException e){
  109.                         System.out.println(e);
  110.                         runOnUiThread(new Runnable() {
  111.                             @Override
  112.                             public void run() {
  113.                                 Toast.makeText(MainActivity.this,"请输入正确的语句",Toast.LENGTH_SHORT).show();
  114.                             }
  115.                         });
  116.  
  117.                     }
  118.                     T=false;
  119.                 }
  120.             }
  121.         }
  122.     }
  123.     class Threads_readSQL extends Thread {
  124.  
  125.         ResultSet rs;
  126.  
  127.  
  128.         @Override
  129.         public void run() {
  130.             while (true) {
  131.                 try {
  132.                     con = MySQLConnections.getConnection();
  133.                 } catch (Exception e) {
  134.                     e.printStackTrace();
  135.                 }
  136.                 try {
  137.                             //注意你数据库中是否有 test 这个表，我新建的表是 test
  138.                             //还有我的属性，是否和我一样呢，不一样就按你自己的来吧
  139.                     String sql = "select name,msg,sign from test";
  140.                     if (con != null) {
  141.                         stmt = con.prepareStatement(sql);
  142.                         // 关闭事务自动提交
  143.                         con.setAutoCommit(false);
  144.                         rs = stmt.executeQuery();//创建数据对象
  145.                         //清空上次发送的信息
  146.                         t1.setText(null);
  147.                         while (rs.next() ) {
  148.                             t1.append(rs.getString(1) + "\n" + rs.getString(2) + "\n\n");
  149.                         }
  150.                         con.commit();
  151.                         rs.close();
  152.                         stmt.close();
  153.                     }
  154.                     //2秒更新一次
  155.                     sleep(2000);
  156.                 } catch (Exception e) {
  157.                     System.out.println(e);
  158.                     runOnUiThread(new Runnable() {
  159.                         @Override
  160.                         public void run() {
  161.                             //Toast.makeText(MainActivity.this,"请输入正确的语句",Toast.LENGTH_SHORT).show();
  162.                         }
  163.                     });
  164.                 }
  165.  
  166.             }
  167.         }
  168.  
  169.     }
  170.  
  171. }

MainActivity布局文件activity_main.xml

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     xmlns:app="http://schemas.android.com/apk/res-auto"
  4.     xmlns:tools="http://schemas.android.com/tools"
  5.     android:layout_width="match_parent"
  6.     android:layout_height="match_parent"
  7.     tools:context=".MainActivity"
  8.     android:orientation="vertical">
  9.  
  10.     // An highlighted block
  11.     <TextView
  12.         android:id="@+id/t1"
  13.         android:layout_width="match_parent"
  14.         android:layout_height="0dp"
  15.         android:layout_weight="10"
  16.         android:text="Hello World!"
  17.         android:layout_marginLeft="8dp"
  18.          />
  19.  
  20.     <LinearLayout
  21.         android:layout_width="match_parent"
  22.         android:layout_height="0dp"
  23.         android:layout_weight="1"
  24.         android:orientation="vertical">
  25.  
  26.         <LinearLayout
  27.             android:layout_width="match_parent"
  28.             android:layout_height="match_parent"
  29.             android:layout_weight="1"
  30.             android:orientation="horizontal">
  31.  
  32.             <EditText
  33.                 android:id="@+id/reviseText"
  34.                 android:layout_width="wrap_content"
  35.                 android:layout_height="wrap_content"
  36.                 android:layout_weight="1"
  37.                 android:ems="10"
  38.                 android:hint="请输入你的昵称"
  39.                 android:inputType="textPersonName" />
  40.  
  41.             <Button
  42.                 android:id="@+id/revise"
  43.                 android:layout_width="wrap_content"
  44.                 android:layout_height="wrap_content"
  45.                 android:layout_weight="1"
  46.                 android:text="修改" />
  47.  
  48.         </LinearLayout>
  49.  
  50.         <LinearLayout
  51.             android:layout_width="match_parent"
  52.             android:layout_height="match_parent"
  53.             android:layout_weight="1"
  54.             android:orientation="horizontal">
  55.  
  56.             <EditText
  57.                 android:id="@+id/msg"
  58.                 android:layout_width="wrap_content"
  59.                 android:layout_height="match_parent"
  60.                 android:layout_weight="1"
  61.                 android:ems="10"
  62.                 android:hint="请输入内容"
  63.                 android:inputType="textPersonName" />
  64.  
  65.             <Button
  66.                 android:id="@+id/button"
  67.                 android:layout_width="wrap_content"
  68.                 android:layout_height="match_parent"
  69.                 android:layout_weight="1"
  70.                 android:text="发送" />
  71.  
  72.         </LinearLayout>
  73.  
  74.     </LinearLayout>
  75.  
  76. </LinearLayout>

MYSQLConnections代码如下

注意我写的注释，用户名，密码，外网地址，外网端口号，数据库名称，这些都要填写你自己的

  1. import java.sql.Connection;
  2. import java.sql.DriverManager;
  3.  
  4. public class MySQLConnections {
  5.     private String driver = "";
  6.     private String dbURL = "";
  7.     private String user = "";
  8.     private String password = "";
  9.     private static MySQLConnections connection = null;
  10.     private MySQLConnections() throws Exception {
  11.         driver = "com.mysql.jdbc.Driver"; //这里根据你下载的依赖包版本会有不同的写法，下载低版本的就是这样写
  12.         //rm-bp1lxt0mjpf6o.mysql.rds.aliyuncs.com:3306 这个是外网地址，3306是外网端口号，这些都需要填写你自己的
  13.         //sqlconsole 这个是你登录你的数据库后新建的数据库（应该不绕口吧）
  14.         dbURL = "jdbc:mysql://rm-bp1lxt0m.mysql.rds.aliyuncs.com:3306/sqlconsole";
  15.         user = "user";  //你新建库时的用户名
  16.         password = "123456"; //你新建库时的密码，这里我就不写我的真密码了
  17.         System.out.println("dbURL:" + dbURL);
  18.     }
  19.     public static Connection getConnection() {
  20.         Connection conn = null;
  21.         if (connection == null) {
  22.             try {
  23.                 connection = new MySQLConnections();
  24.             } catch (Exception e) {
  25.                 e.printStackTrace();
  26.                 return null;
  27.             }
  28.         }
  29.         try {
  30.             Class.forName(connection.driver);
  31.             conn = DriverManager.getConnection(connection.dbURL,
  32.                     connection.user, connection.password);
  33.         } catch (Exception e) {
  34.             e.printStackTrace();
  35.         }
  36.         return conn;
  37.     }
  38. }

AndroidManifest.xml

注意这里要添加网络请求权限

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <manifest xmlns:android="http://schemas.android.com/apk/res/android"
  3.     package="com.example.mysqlconnections">
  4.  
  5.     <uses-permission android:name="android.permission.INTERNET" />
  6.     <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
  7.     <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
  8.  
  9.     <application
  10.         android:usesCleartextTraffic="true"
  11.         android:allowBackup="true"
  12.         android:icon="@mipmap/ic_launcher"
  13.         android:label="@string/app_name"
  14.         android:roundIcon="@mipmap/ic_launcher_round"
  15.         android:supportsRtl="true"
  16.         android:theme="@style/Theme.MyApplication1">
  17.         <activity
  18.             android:name=".MainActivity"
  19.             android:exported="true">
  20.             <intent-filter>
  21.                 <action android:name="android.intent.action.MAIN" />
  22.  
  23.                 <category android:name="android.intent.category.LAUNCHER" />
  24.             </intent-filter>
  25.         </activity>
  26.     </application>
  27.  
  28. </manifest>

最后看我运行结果

Android Studio和阿里云数据库

参考博客

Android Studio 连接阿里云数据库【制作基于数据库的多人远程聊天APP】

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/400798
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号